nebula多次查询返回数据不一致

  • nebula 版本:3.1.0
  • 部署方式:分布式部署
  • 安装方式:源码编译
  • 是否上生产环境:Y
  • 硬件信息
    • 磁盘 SSD
    • CPU: 4核 内存 32G
  • 问题的具体描述
    同一条sql查询多次,返回结果不一致

查询语句

 use orion;match (v:orion_v)--(v2:orion_v) where id(v)=='160052652042' and v2.orion_v.pk_type==2 match (v2:orion_v)--(v3:orion_v) with v2,size(colle
ct(v3)) as c2 return max(c2) as num

返回结果:

schema设置了TTL?

没有设置 结构如下:

:innocent: 这个解释不了,也许多match在那个版本有点问题,建议升到最新版本试试?升级很简单的。

return_1.txt (105.7 KB)
return_null.txt (105.7 KB)

profile分析如上,大佬们帮忙看看

结果为 NULL 的这个查询里面,第一个 match 子句 match (v:orion_v)--(v2:orion_v) where ... 返回的 v2 的个数,比结果为 1 的查询中相同位置的 v2 要少几个,导致最终结果不一样。

可以看看为什么符合条件 id(v)=='160052652042' and v2.orion_v.pk_type==2 的 v2 数量变少了。

不妨先升级下版本吧。

1 个赞
PROFILE MATCH (v:orion_v)--(v2:orion_v)
  WHERE id(v)=='160052652042' and v2.orion_v.pk_type==2 
MATCH (v2:orion_v)--(v3:orion_v) with v2,size(collect(v3)) as c2 
RETURN max(c2) AS num

--- /Users/weyl/Downloads/return_1.txt
+++ /Users/weyl/Downloads/return_null.txt
@@ -1,17 +1,21 @@

-+-----+
-| num |
-+-----+
-| 1   |
-+-----+
-Got 1 rows (time spent 6399/7474 us)
+m01067@nebula) [orion]> profile format='row'
 
-Execution Plan (optimize time 159 us)

++----------+
+| num      |
++----------+
+| __NULL__ |
++----------+
+Got 1 rows (time spent 6523/7071 us)
 
+Execution Plan (optimize time 160 us)
+
 -----+----------------+--------------+-----------------------------------------------------------------------------------------------------------------------+------------------------------------------------------------------------
 | id | name           | dependencies | profiling data                                                                                                        | operator info                                                         |
 -----+----------------+--------------+-----------------------------------------------------------------------------------------------------------------------+------------------------------------------------------------------------
-| 16 | Aggregate      | 15           | ver: 0, rows: 1, execTime: 5us, totalTime: 6us                                                                        | outputVar: {                                                          |
+| 16 | Aggregate      | 15           | ver: 0, rows: 1, execTime: 4us, totalTime: 5us                                                                        | outputVar: {                                                          |
 |    |                |              |                                                                                                                       |   "colNames": [                                                       |
 |    |                |              |                                                                                                                       |     "num"                                                             |
 |    |                |              |                                                                                                                       |   ],                                                                  |
@@ -26,7 +30,7 @@
 |    |                |              |                                                                                                                       |   }                                                                   |
 |    |                |              |                                                                                                                       | ]                                                                     |
 -----+----------------+--------------+-----------------------------------------------------------------------------------------------------------------------+------------------------------------------------------------------------
-| 15 | Project        | 14           | ver: 0, rows: 1, execTime: 6us, totalTime: 6us                                                                        | outputVar: {                                                          |
+| 15 | Project        | 14           | ver: 0, rows: 0, execTime: 1us, totalTime: 2us                                                                        | outputVar: {                                                          |
 |    |                |              |                                                                                                                       |   "colNames": [                                                       |
 |    |                |              |                                                                                                                       |     "v2",                                                             |
 |    |                |              |                                                                                                                       |     "c2"                                                              |
@@ -40,7 +44,7 @@
 |    |                |              |                                                                                                                       |   "size($collect(v3))"                                                |
 |    |                |              |                                                                                                                       | ]                                                                     |
 -----+----------------+--------------+-----------------------------------------------------------------------------------------------------------------------+------------------------------------------------------------------------
-| 14 | Aggregate      | 13           | ver: 0, rows: 1, execTime: 27us, totalTime: 28us                                                                      | outputVar: {                                                          |
+| 14 | Aggregate      | 13           | ver: 0, rows: 0, execTime: 4us, totalTime: 5us                                                                        | outputVar: {                                                          |
 |    |                |              |                                                                                                                       |   "colNames": [                                                       |
 |    |                |              |                                                                                                                       |     "v2",                                                             |
 |    |                |              |                                                                                                                       |     "collect(v3)"                                                     |
@@ -61,7 +65,7 @@
 |    |                |              |                                                                                                                       |   }                                                                   |
 |    |                |              |                                                                                                                       | ]                                                                     |
 -----+----------------+--------------+-----------------------------------------------------------------------------------------------------------------------+------------------------------------------------------------------------
-| 13 | BiInnerJoin    | 18,12        | ver: 0, rows: 1, execTime: 36us, totalTime: 37us                                                                      | outputVar: {                                                          |
+| 13 | BiInnerJoin    | 18,12        | ver: 0, rows: 0, execTime: 30us, totalTime: 30us                                                                      | outputVar: {                                                          |
 |    |                |              |                                                                                                                       |   "colNames": [                                                       |
 |    |                |              |                                                                                                                       |     "v",                                                              |
 |    |                |              |                                                                                                                       |     "v2",                                                             |
@@ -83,7 +87,7 @@
 |    |                |              |                                                                                                                       | ]                                                                     |
 |    |                |              |                                                                                                                       | kind: InnerJoin                                                       |
 -----+----------------+--------------+-----------------------------------------------------------------------------------------------------------------------+------------------------------------------------------------------------
-| 18 | Project        | 17           | ver: 0, rows: 2, execTime: 20us, totalTime: 21us                                                                      | outputVar: {                                                          |
+| 18 | Project        | 17           | ver: 0, rows: 2, execTime: 10us, totalTime: 11us                                                                      | outputVar: {                                                          |
 |    |                |              |                                                                                                                       |   "colNames": [                                                       |
 |    |                |              |                                                                                                                       |     "v",                                                              |
 |    |                |              |                                                                                                                       |     "v2"                                                              |
@@ -97,7 +101,7 @@
 |    |                |              |                                                                                                                       |   "$-.v2 AS v2"                                                       |
 |    |                |              |                                                                                                                       | ]                                                                     |
 -----+----------------+--------------+-----------------------------------------------------------------------------------------------------------------------+------------------------------------------------------------------------
-| 17 | Filter         | 5            | ver: 0, rows: 2, execTime: 60us, totalTime: 61us                                                                      | outputVar: {                                                          |
+| 17 | Filter         | 5            | ver: 0, rows: 2, execTime: 42us, totalTime: 42us                                                                      | outputVar: {                                                          |
 |    |                |              |                                                                                                                       |   "colNames": [                                                       |
 |    |                |              |                                                                                                                       |     "v",                                                              |
 |    |                |              |                                                                                                                       |     "__VAR_0",                                                        |
@@ -111,11 +115,11 @@
 |    |                |              |                                                                                                                       | isStable: false                                                       |
 -----+----------------+--------------+-----------------------------------------------------------------------------------------------------------------------+------------------------------------------------------------------------
 |  5 | AppendVertices | 4            | {                                                                                                                     | outputVar: {                                                          |
-|    |                |              | ver: 0, rows: 16, execTime: 271us, totalTime: 740us                                                                   |   "colNames": [                                                       |
-|    |                |              | "172.29.3.10":9779 exec/total: 200(us)/451(us)                                                                        |     "v",                                                              |
-|    |                |              | "172.29.3.12":9779 exec/total: 172(us)/467(us)                                                                        |     "__VAR_0",                                                        |
-|    |                |              | total_rpc: 528(us)                                                                                                    |     "v2"                                                              |
-|    |                |              | "172.29.3.11":9779 exec/total: 121(us)/336(us)                                                                        |   ],                                                                  |
+|    |                |              | ver: 0, rows: 16, execTime: 263us, totalTime: 910us                                                                   |   "colNames": [                                                       |
+|    |                |              | "172.29.3.10":9779 exec/total: 389(us)/614(us)                                                                        |     "v",                                                              |
+|    |                |              | "172.29.3.12":9779 exec/total: 301(us)/594(us)                                                                        |     "__VAR_0",                                                        |
+|    |                |              | total_rpc: 694(us)                                                                                                    |     "v2"                                                              |
+|    |                |              | "172.29.3.11":9779 exec/total: 283(us)/555(us)                                                                        |   ],                                                                  |
 |    |                |              | }                                                                                                                     |   "type": "DATASET",                                                  |
 |    |                |              |                                                                                                                       |   "name": "__AppendVertices_5"                                        |
 |    |                |              |                                                                                                                       | }                                                                     |
@@ -158,11 +162,11 @@
 |    |                |              |                                                                                                                       | if_track_previous_path: true                                          |
 -----+----------------+--------------+-----------------------------------------------------------------------------------------------------------------------+------------------------------------------------------------------------
 |  4 | Traverse       | 2            | {                                                                                                                     | outputVar: {                                                          |
-|    |                |              | ver: 0, rows: 16, execTime: 143us, totalTime: 831us                                                                   |   "colNames": [                                                       |
+|    |                |              | ver: 0, rows: 16, execTime: 137us, totalTime: 849us                                                                   |   "colNames": [                                                       |
 |    |                |              | step 1: {                                                                                                             |     "v",                                                              |
-|    |                |              | {"172.29.3.11":9779 exec/total/vertices: 267(us)/630(us)/1,                                                           |     "__VAR_0"                                                         |
-|    |                |              | total_rpc_time: 680(us)                                                                                               |   ],                                                                  |
-|    |                |              | storage_detail: {GetNeighborsNode:185(us),HashJoinNode:166(us),RelNode:185(us),SingleEdgeNode:110(us),TagNode:44(us)} |   "type": "DATASET",                                                  |
+|    |                |              | {"172.29.3.11":9779 exec/total/vertices: 317(us)/649(us)/1,                                                           |     "__VAR_0"                                                         |
+|    |                |              | total_rpc_time: 703(us)                                                                                               |   ],                                                                  |
+|    |                |              | storage_detail: {GetNeighborsNode:227(us),HashJoinNode:205(us),RelNode:227(us),SingleEdgeNode:113(us),TagNode:79(us)} |   "type": "DATASET",                                                  |
 |    |                |              | }                                                                                                                     |   "name": "__Traverse_4"                                              |
 |    |                |              | }                                                                                                                     | }                                                                     |
 |    |                |              | }                                                                                                                     | inputVar: __Dedup_2                                                   |
@@ -265,7 +269,7 @@
 |    |                |              |                                                                                                                       | edge filter:                                                          |
 |    |                |              |                                                                                                                       | if_track_previous_path: false                                         |
 -----+----------------+--------------+-----------------------------------------------------------------------------------------------------------------------+------------------------------------------------------------------------
-|  2 | Dedup          | 1            | ver: 0, rows: 1, execTime: 3us, totalTime: 4us                                                                        | outputVar: {                                                          |
+|  2 | Dedup          | 1            | ver: 0, rows: 1, execTime: 4us, totalTime: 4us                                                                        | outputVar: {                                                          |
 |    |                |              |                                                                                                                       |   "colNames": [                                                       |
 |    |                |              |                                                                                                                       |     "_vid"                                                            |
 |    |                |              |                                                                                                                       |   ],                                                                  |
@@ -274,7 +278,7 @@
 |    |                |              |                                                                                                                       | }                                                                     |
 |    |                |              |                                                                                                                       | inputVar: __VAR_2                                                     |
 -----+----------------+--------------+-----------------------------------------------------------------------------------------------------------------------+------------------------------------------------------------------------
-|  1 | PassThrough    | 3            | ver: 0, rows: 0, execTime: 3us, totalTime: 4us                                                                        | outputVar: {                                                          |
+|  1 | PassThrough    | 3            | ver: 0, rows: 0, execTime: 4us, totalTime: 5us                                                                        | outputVar: {                                                          |
 |    |                |              |                                                                                                                       |   "colNames": [                                                       |
 |    |                |              |                                                                                                                       |     "_vid"                                                            |
 |    |                |              |                                                                                                                       |   ],                                                                  |
@@ -283,13 +287,13 @@
 |    |                |              |                                                                                                                       | }                                                                     |
 |    |                |              |                                                                                                                       | inputVar:                                                             |
 -----+----------------+--------------+-----------------------------------------------------------------------------------------------------------------------+------------------------------------------------------------------------
-|  3 | Start          |              | ver: 0, rows: 0, execTime: 0us, totalTime: 14us                                                                       | outputVar: {                                                          |
+|  3 | Start          |              | ver: 0, rows: 0, execTime: 0us, totalTime: 13us                                                                       | outputVar: {                                                          |
 |    |                |              |                                                                                                                       |   "colNames": [],                                                     |
 |    |                |              |                                                                                                                       |   "type": "DATASET",                                                  |
 |    |                |              |                                                                                                                       |   "name": "__Start_3"                                                 |
 |    |                |              |                                                                                                                       | }                                                                     |
 -----+----------------+--------------+-----------------------------------------------------------------------------------------------------------------------+------------------------------------------------------------------------
-| 12 | Project        | 11           | ver: 0, rows: 92, execTime: 318us, totalTime: 319us                                                                   | outputVar: {                                                          |
+| 12 | Project        | 11           | ver: 0, rows: 79, execTime: 293us, totalTime: 294us                                                                   | outputVar: {                                                          |
 |    |                |              |                                                                                                                       |   "colNames": [                                                       |
 |    |                |              |                                                                                                                       |     "v2",                                                             |
 |    |                |              |                                                                                                                       |     "v3"                                                              |
@@ -304,11 +308,11 @@
 |    |                |              |                                                                                                                       | ]                                                                     |
 -----+----------------+--------------+-----------------------------------------------------------------------------------------------------------------------+------------------------------------------------------------------------
 | 11 | AppendVertices | 10           | {                                                                                                                     | outputVar: {                                                          |
-|    |                |              | ver: 0, rows: 92, execTime: 885us, totalTime: 1807us                                                                  |   "colNames": [                                                       |
-|    |                |              | "172.29.3.12":9779 exec/total: 611(us)/907(us)                                                                        |     "v2",                                                             |
-|    |                |              | "172.29.3.10":9779 exec/total: 620(us)/870(us)                                                                        |     "__VAR_1",                                                        |
-|    |                |              | total_rpc: 1060(us)                                                                                                   |     "v3"                                                              |
-|    |                |              | "172.29.3.11":9779 exec/total: 718(us)/994(us)                                                                        |   ],                                                                  |
+|    |                |              | ver: 0, rows: 79, execTime: 697us, totalTime: 1993us                                                                  |   "colNames": [                                                       |
+|    |                |              | "172.29.3.10":9779 exec/total: 765(us)/1006(us)                                                                       |     "v2",                                                             |
+|    |                |              | "172.29.3.11":9779 exec/total: 810(us)/1065(us)                                                                       |     "__VAR_1",                                                        |
+|    |                |              | total_rpc: 1397(us)                                                                                                   |     "v3"                                                              |
+|    |                |              | "172.29.3.12":9779 exec/total: 1005(us)/1334(us)                                                                      |   ],                                                                  |
 |    |                |              | }                                                                                                                     |   "type": "DATASET",                                                  |
 |    |                |              |                                                                                                                       |   "name": "__AppendVertices_11"                                       |
 |    |                |              |                                                                                                                       | }                                                                     |
@@ -351,17 +355,17 @@
 |    |                |              |                                                                                                                       | if_track_previous_path: true                                          |
 -----+----------------+--------------+-----------------------------------------------------------------------------------------------------------------------+------------------------------------------------------------------------
 | 10 | Traverse       | 8            | {                                                                                                                     | outputVar: {                                                          |
-|    |                |              | ver: 0, rows: 92, execTime: 558us, totalTime: 1895us                                                                  |   "colNames": [                                                       |
+|    |                |              | ver: 0, rows: 79, execTime: 501us, totalTime: 1664us                                                                  |   "colNames": [                                                       |
 |    |                |              | step 1: {                                                                                                             |     "v2",                                                             |
-|    |                |              | {"172.29.3.11":9779 exec/total/vertices: 460(us)/695(us)/4,                                                           |     "__VAR_1"                                                         |
-|    |                |              | total_rpc_time: 1326(us)                                                                                              |   ],                                                                  |
-|    |                |              | storage_detail: {GetNeighborsNode:423(us),HashJoinNode:393(us),RelNode:424(us),SingleEdgeNode:355(us),TagNode:24(us)} |   "type": "DATASET",                                                  |
-|    |                |              | }{"172.29.3.12":9779 exec/total/vertices: 368(us)/664(us)/2,                                                          |   "name": "__Traverse_10"                                             |
-|    |                |              | total_rpc_time: 1326(us)                                                                                              | }                                                                     |
-|    |                |              | storage_detail: {GetNeighborsNode:283(us),HashJoinNode:256(us),RelNode:284(us),SingleEdgeNode:200(us),TagNode:41(us)} | inputVar: __Argument_8                                                |
-|    |                |              | }{"172.29.3.10":9779 exec/total/vertices: 982(us)/1226(us)/5,                                                         | space: 172                                                            |
-|    |                |              | total_rpc_time: 1326(us)                                                                                              | dedup: true                                                           |
-|    |                |              | storage_detail: {GetNeighborsNode:908(us),HashJoinNode:838(us),RelNode:908(us),SingleEdgeNode:745(us),TagNode:69(us)} | limit: -1                                                             |
+|    |                |              | {"172.29.3.10":9779 exec/total/vertices: 515(us)/718(us)/3,                                                           |     "__VAR_1"                                                         |
+|    |                |              | total_rpc_time: 1151(us)                                                                                              |   ],                                                                  |
+|    |                |              | storage_detail: {GetNeighborsNode:445(us),HashJoinNode:399(us),RelNode:446(us),SingleEdgeNode:325(us),TagNode:47(us)} |   "type": "DATASET",                                                  |
+|    |                |              | }{"172.29.3.11":9779 exec/total/vertices: 280(us)/474(us)/2,                                                          |   "name": "__Traverse_10"                                             |
+|    |                |              | total_rpc_time: 1151(us)                                                                                              | }                                                                     |
+|    |                |              | storage_detail: {GetNeighborsNode:237(us),HashJoinNode:215(us),RelNode:237(us),SingleEdgeNode:187(us),TagNode:19(us)} | inputVar: __Argument_8                                                |
+|    |                |              | }{"172.29.3.12":9779 exec/total/vertices: 746(us)/1048(us)/2,                                                         | space: 172                                                            |
+|    |                |              | total_rpc_time: 1151(us)                                                                                              | dedup: true                                                           |
+|    |                |              | storage_detail: {GetNeighborsNode:685(us),HashJoinNode:632(us),RelNode:685(us),SingleEdgeNode:590(us),TagNode:27(us)} | limit: -1                                                             |
 |    |                |              | }                                                                                                                     | filter:                                                               |
 |    |                |              | }                                                                                                                     | orderBy: []                                                           |
 |    |                |              | }                                                                                                                     | src: id($-.v2)                                                        |
@@ -458,7 +462,7 @@
 |    |                |              |                                                                                                                       | edge filter:                                                          |
 |    |                |              |                                                                                                                       | if_track_previous_path: false                                         |
 -----+----------------+--------------+-----------------------------------------------------------------------------------------------------------------------+------------------------------------------------------------------------
-|  8 | Argument       |              | ver: 0, rows: 11, execTime: 0us, totalTime: 32us                                                                      | outputVar: {                                                          |
+|  8 | Argument       |              | ver: 0, rows: 7, execTime: 0us, totalTime: 27us                                                                       | outputVar: {                                                          |
 |    |                |              |                                                                                                                       |   "colNames": [                                                       |
 |    |                |              |                                                                                                                       |     "v2"                                                              |
 |    |                |              |                                                                                                                       |   ],                                                                  |
@@ -474,5 +478,5 @@
 |    |                |              |                                                                                                                       | }                                                                     |
 -----+----------------+--------------+-----------------------------------------------------------------------------------------------------------------------+------------------------------------------------------------------------
 
-Wed, 28 Jun 2023 20:38:14 CST
+Wed, 28 Jun 2023 20:35:45 CST

看计划,只能看到有些算子取数据的节点不同,其他都是一致的,不太确定是否是不同的副本数据不一致导致的:

如果可以,也建议升级新版本的 nebula 测试。

1 个赞

Yee 老师,这里 passthrough row == 0 怎么理解呢?这意味着 id(v)=='160052652042' 没匹配上?这样似乎后续不应该有结果

这是个逻辑算子,有时候是用来放一些常量数据传给后面的算子

原来如此:heart:

建议升级到哪个版本 谢谢

目前最新版本是 3.5。

问题已解决,换了一种SQL写法

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