jar包批量导入的数据,但只有个别查询语句可以查到,大部分语句查不到边的存在

  • nebula 版本:3.0.0
  • 部署方式:分布式
  • 安装方式:RPM
  • 是否为线上版本:Y
  • 硬件信息
    • 磁盘 SATA
    • CPU、内存信息 三台虚拟机:都是4核、8g内存
  • 问题的具体描述
    javr包批量从其他数据库导入数据后,点正常。
    但是边不正常,Match查询时不限定边类型可以查到,而限定边类型后就查无数据。
    同时我用点去遍历子图,证明是存在这些边的

Match:指定边类型查询

(shixingr@nebula) [field_blood_relation_space]> MATCH ()<-[e:table_rely]-() RETURN e limit 100;
+---+
| e |
+---+
+---+
Empty set (time spent 1952/2372 us)

Fri, 01 Apr 2022 19:04:40 CST

(shixingr@nebula) [field_blood_relation_space]> MATCH ()<-[e:table_rely]-() RETURN e;
+---+
| e |
+---+
+---+
Empty set (time spent 2061/2554 us)

Match:不指定边类型查询

(shixingr@nebula) [field_blood_relation_space]> MATCH ()<-[e]-() RETURN e limit 100;
+--------------------------------------------------------------------------------------------------------------------------------------------------------------+
| e                                                                                                                                                            |
+--------------------------------------------------------------------------------------------------------------------------------------------------------------+
| [:table_rely "dwd.dwd_log_detail_d"->" tujia_tmp.cpc_cost_city" @0 {}]                                                                                       |
| [:table_rely "dws.dws_house_d"->" tujia_tmp.cpc_cost_city" @0 {}]                                                                                            |
| [:table_rely "dws.dws_order"->" tujia_tmp.cpc_cost_city" @0 {}]                                                                                              |
| [:table_rely "ods_ploutos_fabs.market_record"->" tujia_tmp.cpc_cost_city" @0 {}]                                                                             |
| [:table_rely "x1"->" tujia_tmp.cpc_cost_city" @0 {}]                                                                                                         |
| [:table_rely "meta_data"->"`ods_callcenter`.`callgroup`" @0 {}]                                                                                              |
| [:table_rely "tujia_tmp.ods_callcenter_callgroup_tmp"->"`ods_callcenter`.`callgroup`" @0 {}]                                                                 |
| [:table_rely "meta_data"->"`ods_crm`.`busopty_base`" @0 {}]                                                                                                  |
| [:table_rely "tujia_tmp.ods_crm_busopty_base_tmp"->"`ods_crm`.`busopty_base`" @0 {}]                                                                         |
| [:table_rely "meta_data"->"`ods_csc`.`spsupcitymapping`" @0 {}]                                                                                              |
| [:table_rely "tujia_tmp.ods_csc_spsupcitymapping_tmp"->"`ods_csc`.`spsupcitymapping`" @0 {}]                                                                 |
| [:table_rely "meta_data"->"`ods_csc`.`spsupplierinfo`" @0 {}]                                                                                                |
| [:table_rely "tujia_tmp.ods_csc_spsupplierinfo_tmp"->"`ods_csc`.`spsupplierinfo`" @0 {}]                                                                     |
| [:table_rely "meta_data"->"`ods_distributionmanager`.`ctrip_hotel_partial_origin_data`" @0 {}]                                                               |
| [:table_rely "tujia_tmp.ods_distributionmanager_ctrip_hotel_partial_origin_data_tmp"->"`ods_distributionmanager`.`ctrip_hotel_partial_origin_data`" @0 {}]   |
| [:table_rely "meta_data"->"`ods_distributionmanager`.`ctrip_prodcit_rule_relation_info`" @0 {}]                                                              |
| [:table_rely "tujia_tmp.ods_distributionmanager_ctrip_prodcit_rule_relation_info_tmp"->"`ods_distributionmanager`.`ctrip_prodcit_rule_relation_info`" @0 {}] |
| [:table_rely "meta_data"->"`ods_houseimport_config`.`api_supplier_online_log`" @0 {}]                                                                        |
| [:table_rely "tujia_tmp.ods_houseimport_config_api_supplier_online_log_tmp"->"`ods_houseimport_config`.`api_supplier_online_log`" @0 {}]                     |
| [:table_rely "meta_data"->"`ods_ploutos_fas`.`account_transaction`" @0 {}]                                                                                   |
| [:table_rely "ods_order_data.notify_queue"->"`ods_ploutos_fas`.`account_transaction`" @0 {}]                                                                 |
| [:table_rely "ods_tns_order_notice.b_notice_queue"->"`ods_ploutos_fas`.`account_transaction`" @0 {}]                                                         |
| [:table_rely "ods_tns_order_notice.notice_queue"->"`ods_ploutos_fas`.`account_transaction`" @0 {}]                                                           |
| [:table_rely "ods_tns_order_notice.notify_queue"->"`ods_ploutos_fas`.`account_transaction`" @0 {}]                                                           |
| [:table_rely "tujia_tmp.ods_ploutos_fas_account_transaction_tmp"->"`ods_ploutos_fas`.`account_transaction`" @0 {}]                                           |
| [:table_rely "meta_data"->"`ods_ploutos_fcss`.`biz_order_item`" @0 {}]                                                                                       |
| [:table_rely "tujia_tmp.ods_ploutos_fcss_biz_order_item_tmp"->"`ods_ploutos_fcss`.`biz_order_item`" @0 {}]                                                   |
| [:table_rely "ods_tujiaorder.orderreturncash"->"`ods_systemoperation`.`pageredirectconfig`" @0 {}]                                                           |
| [:table_rely "meta_data"->"`ods_tc_iris`.`t_message_info`" @0 {}]                                                                                            |
| [:table_rely "tujia_tmp.ods_tc_iris_t_message_info_tmp"->"`ods_tc_iris`.`t_message_info`" @0 {}]                                                             |

get subgraph
获取子图也可查到:
语句如下,打印结果很多 不在此粘贴了

get subgraph 3 steps from "ods_tujia_member.member" out table_rely yield edges as table_rely;

Fri, 01 Apr 2022 19:04:47 CST

:thinking: 可以帮忙看下数据导入是不是成功了吗?

SUBMIT JOB STATS

执行下,然后会得到个 job id,然后

SHOW JOB id

完成了之后,执行

SHOW STATS

看下导入的数据和你原来的是不是一样


成功了 边的数量和预期也一模一样
就是用以下两种方法查不出来。
当时是想查看导完后边的数量来着,发现这个问题了

1 个赞

:thinking: 不好意思哈,我再来核实下,你指定的边类型查询 MATCH 语句,那些边类型是不是都创建索引了

嗯对创建了,不然lookup不能查询。。

1 个赞

image

执行一下 profile MATCH ()<-[e:table_rely]-() RETURN e;

1 个赞

谢谢 这个问题上周我重新导入了一下数据解决了。。
在这请教您一个问题关于初始化连接池的问题。
多个地方要初始化一个地址或者说一个连接池多个地方用 该怎么办 java-nebula


会有这样类似的问题。
因为java里边出了问题。所以console都进不去了

这个应该是连接池满了,:thinking: 不过 连接池这个我不是很熟,我去找个研发同学。稍等。

三克油

之前 Anyzm 教的 release 不行吗?

哦 那个是释放session 是可以的
这个问题主要是 连接池的问题

连接池应该是全局只存在一个的, 只初始化一次, 每次要新建session的时候从同一个连接池实例申请, 连接池在析构的时候会释放链接, 一般不用手动去释放

1 个赞

啊 和我想的一样
是不是要在工具类里定义一个静态初始化的,类似单例一样
因为我不止一个地方要用连接池。
目前的代码是每次调用先判断 连接池是否空,空则初始化

然后如果连接已存在怎么清除掉呀。如下的情况

  1. 是的, 可以把连接池作为单例使用
  2. 这个错误是链接断了, 检查下服务状态
2 个赞

好 理解了 应该能解决了 谢谢

此话题已在最后回复的 7 天后被自动关闭。不再允许新回复。