超时调用graph日志
I20250122 11:38:26.190208 984348 ClientSession.cpp:43] Add query: match (c:tag1) where id(c)=='E0mhlhkIu0AMuKqmG' match (c)<-[:edge1]->(m:tag2)-[:goods]->(o:info) return count(distinct case when o.info.ob_status in [0,2] then m.tag2.cd else null end) as v1, epId: 1782211
I20250122 11:38:26.190217 984348 QueryInstance.cpp:80] Parsing query: match (c:tag1) where id(c)=='E0mhlhkIu0AMuKqmG' match (c)<-[:edge1]->(m:tag2)-[:goods]->(o:info) return count(distinct case when o.info.ob_status in [0,2] then m.tag2.cd else null end) as v1
I20250122 11:38:26.190258 984348 Symbols.cpp:48] New variable for: __Start_0
I20250122 11:38:26.190261 984348 PlanNode.cpp:27] New variable: __Start_0
I20250122 11:38:26.190266 984348 Validator.cpp:350] Space chosen, name: graph_v1 id: 2
I20250122 11:38:26.190296 984348 Symbols.cpp:48] New variable for: __VAR_0
I20250122 11:38:26.190300 984348 AnonVarGenerator.h:28] Build anon var: __VAR_0
I20250122 11:38:26.190303 984348 Symbols.cpp:48] New variable for: __VAR_1
I20250122 11:38:26.190306 984348 AnonVarGenerator.h:28] Build anon var: __VAR_1
I20250122 11:38:26.190331 984348 Symbols.cpp:48] New variable for: __VAR_2
I20250122 11:38:26.190335 984348 AnonVarGenerator.h:28] Build anon var: __VAR_2
I20250122 11:38:26.190340 984348 Symbols.cpp:48] New variable for: __PassThrough_1
I20250122 11:38:26.190342 984348 PlanNode.cpp:27] New variable: __PassThrough_1
I20250122 11:38:26.190346 984348 Symbols.cpp:48] New variable for: __Dedup_2
I20250122 11:38:26.190349 984348 PlanNode.cpp:27] New variable: __Dedup_2
I20250122 11:38:26.190353 984348 MatchPathPlanner.cpp:126] Find starts: 0, Pattern has 0 edges, root: __Dedup_2, colNames: _vid
I20250122 11:38:26.190359 984348 Symbols.cpp:48] New variable for: __Start_3
I20250122 11:38:26.190362 984348 PlanNode.cpp:27] New variable: __Start_3
I20250122 11:38:26.190366 984348 Symbols.cpp:48] New variable for: __AppendVertices_4
I20250122 11:38:26.190369 984348 PlanNode.cpp:27] New variable: __AppendVertices_4
I20250122 11:38:26.190423 984348 Symbols.cpp:48] New variable for: __Project_5
I20250122 11:38:26.190425 984348 PlanNode.cpp:27] New variable: __Project_5
I20250122 11:38:26.190430 984348 Symbols.cpp:48] New variable for: __Argument_6
I20250122 11:38:26.190433 984348 PlanNode.cpp:27] New variable: __Argument_6
I20250122 11:38:26.190438 984348 MatchPathPlanner.cpp:126] Find starts: 0, Pattern has 2 edges, root: __Argument_6, colNames: c
I20250122 11:38:26.190441 984348 Symbols.cpp:48] New variable for: __Traverse_7
I20250122 11:38:26.190443 984348 PlanNode.cpp:27] New variable: __Traverse_7
I20250122 11:38:26.190476 984348 ServerBasedSchemaManager.cpp:68] Get Edge Schema Space 2, EdgeType 108, Version -1
I20250122 11:38:26.190483 984348 Symbols.cpp:48] New variable for: __Traverse_8
I20250122 11:38:26.190486 984348 PlanNode.cpp:27] New variable: __Traverse_8
I20250122 11:38:26.190518 984348 ServerBasedSchemaManager.cpp:68] Get Edge Schema Space 2, EdgeType 92, Version -1
I20250122 11:38:26.190521 984348 ServerBasedSchemaManager.cpp:68] Get Edge Schema Space 2, EdgeType 104, Version -1
I20250122 11:38:26.190526 984348 Symbols.cpp:48] New variable for: __AppendVertices_9
I20250122 11:38:26.190528 984348 PlanNode.cpp:27] New variable: __AppendVertices_9
I20250122 11:38:26.190573 984348 Symbols.cpp:48] New variable for: __Project_10
I20250122 11:38:26.190577 984348 PlanNode.cpp:27] New variable: __Project_10
I20250122 11:38:26.190582 984348 Symbols.cpp:48] New variable for: __HashInnerJoin_11
I20250122 11:38:26.190584 984348 PlanNode.cpp:27] New variable: __HashInnerJoin_11
I20250122 11:38:26.190593 984348 Symbols.cpp:48] New variable for: __Aggregate_12
I20250122 11:38:26.190595 984348 PlanNode.cpp:27] New variable: __Aggregate_12
I20250122 11:38:26.190598 984348 ReturnClausePlanner.cpp:52] return root: __Aggregate_12 colNames: v1
I20250122 11:38:26.190601 984348 MatchPlanner.cpp:172] root(Aggregate_12): __Aggregate_12, tail(Start_3): __Start_3
I20250122 11:38:26.190604 984348 Validator.cpp:409] root: Aggregate tail: Start
I20250122 11:38:26.190608 984348 Validator.cpp:409] root: Aggregate tail: Start
I20250122 11:38:26.190644 984348 Symbols.cpp:48] New variable for: __AppendVertices_13
I20250122 11:38:26.190647 984348 PlanNode.cpp:27] New variable: __AppendVertices_13
I20250122 11:38:26.190721 984348 Symbols.cpp:48] New variable for: __AppendVertices_14
I20250122 11:38:26.190724 984348 PlanNode.cpp:27] New variable: __AppendVertices_14
I20250122 11:38:26.190744 984348 Symbols.cpp:48] New variable for: __Traverse_15
I20250122 11:38:26.190747 984348 PlanNode.cpp:27] New variable: __Traverse_15
I20250122 11:38:26.190781 984348 Symbols.cpp:48] New variable for: __AppendVertices_16
I20250122 11:38:26.190784 984348 PlanNode.cpp:27] New variable: __AppendVertices_16
I20250122 11:38:26.191218 984386 ThriftClientManager-inl.h:47] Getting a client to "ip1":9779
I20250122 11:38:26.191777 984386 AsyncSocket.cpp:2711] this=0x7f1cb3411000, AsyncSocket::handleRead() got 108 bytes
I20250122 11:38:26.191910 984387 ThriftClientManager-inl.h:47] Getting a client to "ip1":9779
I20250122 11:38:26.192570 984387 AsyncSocket.cpp:2711] this=0x7f1cb2611800, AsyncSocket::handleRead() got 323 bytes
I20250122 11:38:26.192749 984388 ThriftClientManager-inl.h:47] Getting a client to "ip3":9779
I20250122 11:38:26.192763 984390 ThriftClientManager-inl.h:47] Getting a client to "ip5":9779
I20250122 11:38:26.192771 984391 ThriftClientManager-inl.h:47] Getting a client to "ip7":9779
I20250122 11:38:26.192756 984389 ThriftClientManager-inl.h:47] Getting a client to "ip1":9779
I20250122 11:38:26.193486 984389 AsyncSocket.cpp:2711] this=0x7f1cb0a0f000, AsyncSocket::handleRead() got 424 bytes
I20250122 11:38:26.193681 984391 AsyncSocket.cpp:2711] this=0x7f1cae611000, AsyncSocket::handleRead() got 634 bytes
I20250122 11:38:26.194018 984388 AsyncSocket.cpp:2711] this=0x7f1cb1811000, AsyncSocket::handleRead() got 218 bytes
I20250122 11:38:26.201900 984404 AsyncSocket.cpp:2711] this=0x7f1ca3219000, AsyncSocket::handleRead() got 2048 bytes
##### 以下开始有差异
I20250122 11:38:26.201920 984404 AsyncSocket.cpp:2711] this=0x7f1ca3219000, AsyncSocket::handleRead() got 4269 bytes
I20250122 11:38:26.201949 984367 GraphSessionManager.cpp:40] Find session from cache: 1737515700489522
I20250122 11:38:26.201980 984367 ClientSession.cpp:43] Add query: insert edge ...
I20250122 11:38:26.201990 984367 QueryInstance.cpp:80] Parsing query: insert edge ...
I20250122 11:38:26.202180 984367 Symbols.cpp:48] New variable for: __Start_0
I20250122 11:38:26.202185 984367 PlanNode.cpp:27] New variable: __Start_0
I20250122 11:38:26.202189 984367 Validator.cpp:350] Space chosen, name: graph_v1 id: 2
I20250122 11:38:26.202193 984367 ServerBasedSchemaManager.cpp:68] Get Edge Schema Space 2, EdgeType 82, Version -1
I20250122 11:38:26.202200 984367 Symbols.cpp:48] New variable for: __InsertEdges_1
I20250122 11:38:26.202203 984367 PlanNode.cpp:27] New variable: __InsertEdges_1
I20250122 11:38:26.202207 984367 Validator.cpp:350] Space chosen, name: graph_v1 id: 2
I20250122 11:38:26.202244 984367 ServerBasedSchemaManager.cpp:68] Get Edge Schema Space 2, EdgeType 141, Version -1
I20250122 11:38:26.202250 984367 ServerBasedSchemaManager.cpp:68] Get Edge Schema Space 2, EdgeType 141, Version -1
I20250122 11:38:26.202255 984367 Symbols.cpp:48] New variable for: __UpdateEdge_2
I20250122 11:38:26.202258 984367 PlanNode.cpp:27] New variable: __UpdateEdge_2
I20250122 11:38:26.202262 984367 Symbols.cpp:48] New variable for: __UpdateEdge_3
I20250122 11:38:26.202265 984367 PlanNode.cpp:27] New variable: __UpdateEdge_3
I20250122 11:38:26.202268 984367 Validator.cpp:350] Space chosen, name: graph_v1 id: 2
I20250122 11:38:26.202271 984367 ServerBasedSchemaManager.cpp:68] Get Edge Schema Space 2, EdgeType 92, Version -1
I20250122 11:38:26.202275 984367 Symbols.cpp:48] New variable for: __InsertEdges_4
I20250122 11:38:26.202278 984367 PlanNode.cpp:27] New variable: __InsertEdges_4
I20250122 11:38:26.202281 984367 Validator.cpp:350] Space chosen, name: graph_v1 id: 2
I20250122 11:38:26.202311 984367 Symbols.cpp:48] New variable for: __UpdateEdge_5
I20250122 11:38:26.202314 984367 PlanNode.cpp:27] New variable: __UpdateEdge_5
I20250122 11:38:26.202317 984367 Symbols.cpp:48] New variable for: __UpdateEdge_6
I20250122 11:38:26.202320 984367 PlanNode.cpp:27] New variable: __UpdateEdge_6
I20250122 11:38:26.202323 984367 Validator.cpp:350] Space chosen, name: graph_v1 id: 2
I20250122 11:38:26.202327 984367 ServerBasedSchemaManager.cpp:68] Get Edge Schema Space 2, EdgeType 82, Version -1
I20250122 11:38:26.202330 984367 Symbols.cpp:48] New variable for: __InsertEdges_7
I20250122 11:38:26.202333 984367 PlanNode.cpp:27] New variable: __InsertEdges_7
I20250122 11:38:26.202337 984367 Validator.cpp:350] Space chosen, name: graph_v1 id: 2
I20250122 11:38:26.202365 984367 ServerBasedSchemaManager.cpp:68] Get Edge Schema Space 2, EdgeType 79, Version -1
I20250122 11:38:26.202370 984367 ServerBasedSchemaManager.cpp:68] Get Edge Schema Space 2, EdgeType 79, Version -1
I20250122 11:38:26.202375 984367 Symbols.cpp:48] New variable for: __UpdateEdge_8
I20250122 11:38:26.202378 984367 PlanNode.cpp:27] New variable: __UpdateEdge_8
I20250122 11:38:26.202381 984367 Symbols.cpp:48] New variable for: __UpdateEdge_9
I20250122 11:38:26.202384 984367 PlanNode.cpp:27] New variable: __UpdateEdge_9
I20250122 11:38:26.202389 984367 Validator.cpp:350] Space chosen, name: graph_v1 id: 2
I20250122 11:38:26.202419 984367 ServerBasedSchemaManager.cpp:68] Get Edge Schema Space 2, EdgeType 141, Version -1
I20250122 11:38:26.202422 984367 ServerBasedSchemaManager.cpp:68] Get Edge Schema Space 2, EdgeType 141, Version -1
I20250122 11:38:26.202427 984367 Symbols.cpp:48] New variable for: __UpdateEdge_10
I20250122 11:38:26.202430 984367 PlanNode.cpp:27] New variable: __UpdateEdge_10
I20250122 11:38:26.202433 984367 Symbols.cpp:48] New variable for: __UpdateEdge_11
I20250122 11:38:26.202436 984367 PlanNode.cpp:27] New variable: __UpdateEdge_11
I20250122 11:38:26.202440 984367 Validator.cpp:350] Space chosen, name: graph_v1 id: 2
I20250122 11:38:26.202442 984367 ServerBasedSchemaManager.cpp:68] Get Edge Schema Space 2, EdgeType 82, Version -1
I20250122 11:38:26.202446 984367 Symbols.cpp:48] New variable for: __InsertEdges_12
I20250122 11:38:26.202450 984367 PlanNode.cpp:27] New variable: __InsertEdges_12
I20250122 11:38:26.202453 984367 Validator.cpp:350] Space chosen, name: graph_v1 id: 2
I20250122 11:38:26.202481 984367 ServerBasedSchemaManager.cpp:68] Get Edge Schema Space 2, EdgeType 79, Version -1
I20250122 11:38:26.202483 984367 ServerBasedSchemaManager.cpp:68] Get Edge Schema Space 2, EdgeType 79, Version -1
I20250122 11:38:26.202488 984367 Symbols.cpp:48] New variable for: __UpdateEdge_13
I20250122 11:38:26.202491 984367 PlanNode.cpp:27] New variable: __UpdateEdge_13
I20250122 11:38:26.202494 984367 Symbols.cpp:48] New variable for: __UpdateEdge_14
I20250122 11:38:26.202497 984367 PlanNode.cpp:27] New variable: __UpdateEdge_14
I20250122 11:38:26.202500 984367 Validator.cpp:350] Space chosen, name: graph_v1 id: 2
I20250122 11:38:26.202531 984367 ServerBasedSchemaManager.cpp:68] Get Edge Schema Space 2, EdgeType 81, Version -1
I20250122 11:38:26.202535 984367 ServerBasedSchemaManager.cpp:68] Get Edge Schema Space 2, EdgeType 81, Version -1
I20250122 11:38:26.202540 984367 Symbols.cpp:48] New variable for: __UpdateEdge_15
I20250122 11:38:26.202543 984367 PlanNode.cpp:27] New variable: __UpdateEdge_15
I20250122 11:38:26.202546 984367 Symbols.cpp:48] New variable for: __UpdateEdge_16
I20250122 11:38:26.202549 984367 PlanNode.cpp:27] New variable: __UpdateEdge_16
I20250122 11:38:26.202560 984367 Validator.cpp:350] Space chosen, name: graph_v1 id: 2
I20250122 11:38:26.202591 984367 Symbols.cpp:48] New variable for: __UpdateEdge_17
I20250122 11:38:26.202594 984367 PlanNode.cpp:27] New variable: __UpdateEdge_17
I20250122 11:38:26.202597 984367 Symbols.cpp:48] New variable for: __UpdateEdge_18
I20250122 11:38:26.202600 984367 PlanNode.cpp:27] New variable: __UpdateEdge_18
I20250122 11:38:26.202603 984367 Validator.cpp:350] Space chosen, name: graph_v1 id: 2
I20250122 11:38:26.202605 984367 ServerBasedSchemaManager.cpp:68] Get Edge Schema Space 2, EdgeType 82, Version -1
I20250122 11:38:26.202610 984367 Symbols.cpp:48] New variable for: __InsertEdges_19
I20250122 11:38:26.202613 984367 PlanNode.cpp:27] New variable: __InsertEdges_19
I20250122 11:38:26.202616 984367 Validator.cpp:350] Space chosen, name: graph_v1 id: 2
I20250122 11:38:26.202646 984367 Symbols.cpp:48] New variable for: __UpdateEdge_20
I20250122 11:38:26.202648 984367 PlanNode.cpp:27] New variable: __UpdateEdge_20
I20250122 11:38:26.202651 984367 Symbols.cpp:48] New variable for: __UpdateEdge_21
I20250122 11:38:26.202654 984367 PlanNode.cpp:27] New variable: __UpdateEdge_21
I20250122 11:38:26.202658 984367 Validator.cpp:350] Space chosen, name: graph_v1 id: 2
I20250122 11:38:26.202661 984367 ServerBasedSchemaManager.cpp:68] Get Edge Schema Space 2, EdgeType 92, Version -1
I20250122 11:38:26.202665 984367 Symbols.cpp:48] New variable for: __InsertEdges_22
I20250122 11:38:26.202668 984367 PlanNode.cpp:27] New variable: __InsertEdges_22
I20250122 11:38:26.202672 984367 Validator.cpp:409] root: InsertEdges tail: Start
I20250122 11:38:26.202975 984392 ThriftClientManager-inl.h:47] Getting a client to "ip2":9779
I20250122 11:38:26.202988 984393 ThriftClientManager-inl.h:47] Getting a client to "ip7":9779
I20250122 11:38:26.203357 984392 AsyncSocket.cpp:2711] this=0x7f1cad812000, AsyncSocket::handleRead() got 34 bytes
I20250122 11:38:26.203384 984393 AsyncSocket.cpp:2711] this=0x7f1caca11c00, AsyncSocket::handleRead() got 34 bytes
I20250122 11:38:26.203418 984360 InsertExecutor.cpp:68] Add edge time: 482us
I20250122 11:38:26.203474 984394 ThriftClientManager-inl.h:47] Getting a client to "ip1":9779
I20250122 11:38:26.203711 984394 AsyncSocket.cpp:2711] this=0x7f1cabc11c00, AsyncSocket::handleRead() got 61 bytes
I20250122 11:38:26.203732 984394 StorageClientBase-inl.h:186] Failure! Failed part 60, failed part -3043
I20250122 11:38:26.203755 984342 UpdateExecutor.cpp:113] Update edge time: 313us
I20250122 11:38:26.203814 984395 ThriftClientManager-inl.h:47] Getting a client to "ip2":9779
I20250122 11:38:26.204020 984395 AsyncSocket.cpp:2711] this=0x7f1caae18c00, AsyncSocket::handleRead() got 62 bytes
I20250122 11:38:26.204033 984395 StorageClientBase-inl.h:186] Failure! Failed part 85, failed part -3043
I20250122 11:38:26.204049 984367 UpdateExecutor.cpp:113] Update edge time: 269us
I20250122 11:38:26.204121 984396 ThriftClientManager-inl.h:47] Getting a client to "ip1":9779
I20250122 11:38:26.204125 984397 ThriftClientManager-inl.h:47] Getting a client to "ip7":9779
I20250122 11:38:26.204452 984397 AsyncSocket.cpp:2711] this=0x7f1ca9218800, AsyncSocket::handleRead() got 34 bytes
I20250122 11:38:26.204501 984396 AsyncSocket.cpp:2711] this=0x7f1caa01a400, AsyncSocket::handleRead() got 34 bytes
I20250122 11:38:26.204535 984342 InsertExecutor.cpp:68] Add edge time: 454us
I20250122 11:38:26.204589 984400 ThriftClientManager-inl.h:47] Getting a client to "ip1":9779
I20250122 11:38:26.205076 984400 AsyncSocket.cpp:2711] this=0x7f1ca6a19800, AsyncSocket::handleRead() got 55 bytes
I20250122 11:38:26.205111 984354 UpdateExecutor.cpp:113] Update edge time: 560us
I20250122 11:38:26.205169 984402 ThriftClientManager-inl.h:47] Getting a client to "ip6":9779
I20250122 11:38:26.205672 984402 AsyncSocket.cpp:2711] this=0x7f1ca4e19c00, AsyncSocket::handleRead() got 55 bytes
I20250122 11:38:26.205713 984348 UpdateExecutor.cpp:113] Update edge time: 577us
I20250122 11:38:26.205775 984404 ThriftClientManager-inl.h:47] Getting a client to "ip6":9779
I20250122 11:38:26.205787 984405 ThriftClientManager-inl.h:47] Getting a client to "ip4":9779
I20250122 11:38:26.206146 984404 AsyncSocket.cpp:2711] this=0x7f1ca321a400, AsyncSocket::handleRead() got 34 bytes
I20250122 11:38:26.206187 984405 AsyncSocket.cpp:2711] this=0x7f1ca2418800, AsyncSocket::handleRead() got 34 bytes
I20250122 11:38:26.206228 984348 InsertExecutor.cpp:68] Add edge time: 493us
I20250122 11:38:26.206269 984406 ThriftClientManager-inl.h:47] Getting a client to "ip2":9779
I20250122 11:38:26.206454 984406 AsyncSocket.cpp:2711] this=0x7f1ca1618c00, AsyncSocket::handleRead() got 61 bytes
I20250122 11:38:26.206466 984406 StorageClientBase-inl.h:186] Failure! Failed part 125, failed part -3043
I20250122 11:38:26.206481 984348 UpdateExecutor.cpp:113] Update edge time: 237us
I20250122 11:38:26.206521 984407 ThriftClientManager-inl.h:47] Getting a client to "ip1":9779
I20250122 11:38:26.206743 984407 AsyncSocket.cpp:2711] this=0x7f1ca081a400, AsyncSocket::handleRead() got 60 bytes
I20250122 11:38:26.206755 984407 StorageClientBase-inl.h:186] Failure! Failed part 18, failed part -3043
I20250122 11:38:26.206772 984354 UpdateExecutor.cpp:113] Update edge time: 275us
I20250122 11:38:26.206811 984408 ThriftClientManager-inl.h:47] Getting a client to "ip2":9779
I20250122 11:38:26.206979 984408 AsyncSocket.cpp:2711] this=0x7f1c9fa1a400, AsyncSocket::handleRead() got 61 bytes
I20250122 11:38:26.207000 984408 StorageClientBase-inl.h:186] Failure! Failed part 125, failed part -3043
I20250122 11:38:26.207021 984348 UpdateExecutor.cpp:113] Update edge time: 230us
I20250122 11:38:26.207063 984409 ThriftClientManager-inl.h:47] Getting a client to "ip3":9779
I20250122 11:38:26.207288 984409 AsyncSocket.cpp:2711] this=0x7f1c9ec3b000, AsyncSocket::handleRead() got 62 bytes
I20250122 11:38:26.207309 984409 StorageClientBase-inl.h:186] Failure! Failed part 133, failed part -3043
I20250122 11:38:26.207329 984360 UpdateExecutor.cpp:113] Update edge time: 290us
I20250122 11:38:26.207401 984410 ThriftClientManager-inl.h:47] Getting a client to "ip2":9779
I20250122 11:38:26.207408 984411 ThriftClientManager-inl.h:47] Getting a client to "ip4":9779
I20250122 11:38:26.207732 984410 AsyncSocket.cpp:2711] this=0x7f1c9de19000, AsyncSocket::handleRead() got 34 bytes
I20250122 11:38:26.207758 984411 AsyncSocket.cpp:2711] this=0x7f1c9d07b000, AsyncSocket::handleRead() got 34 bytes
I20250122 11:38:26.207798 984360 InsertExecutor.cpp:68] Add edge time: 445us
I20250122 11:38:26.207841 984412 ThriftClientManager-inl.h:47] Getting a client to "ip2":9779
I20250122 11:38:26.208014 984412 AsyncSocket.cpp:2711] this=0x7f1c9c219c00, AsyncSocket::handleRead() got 61 bytes
I20250122 11:38:26.208029 984412 StorageClientBase-inl.h:186] Failure! Failed part 125, failed part -3043
I20250122 11:38:26.208045 984360 UpdateExecutor.cpp:113] Update edge time: 227us
I20250122 11:38:26.208087 984377 ThriftClientManager-inl.h:47] Getting a client to "ip5":9779
I20250122 11:38:26.806746 984396 AsyncSocket.cpp:2711] this=0x7f1caa018800, AsyncSocket::handleRead() got 125 bytes
I20250122 11:38:26.806788 984367 UpdateExecutor.cpp:61] Update vertice time: 764412us
I20250122 11:38:26.806850 984378 ThriftClientManager-inl.h:47] Getting a client to "ip4":9779
I20250122 11:38:26.807354 984378 AsyncSocket.cpp:2711] this=0x7f1cba614c00, AsyncSocket::handleRead() got 121 bytes
I20250122 11:38:26.807391 984360 UpdateExecutor.cpp:61] Update vertice time: 572us
I20250122 11:38:26.807435 984379 ThriftClientManager-inl.h:47] Getting a client to "ip4":9779
I20250122 11:38:26.807861 984379 AsyncSocket.cpp:2711] this=0x7f1cb9813800, AsyncSocket::handleRead() got 121 bytes
I20250122 11:38:26.807900 984367 UpdateExecutor.cpp:61] Update vertice time: 486us
I20250122 11:38:26.807946 984380 ThriftClientManager-inl.h:47] Getting a client to "ip7":9779
I20250122 11:38:26.808384 984380 AsyncSocket.cpp:2711] this=0x7f1cb8a13800, AsyncSocket::handleRead() got 121 bytes
I20250122 11:38:26.808410 984367 UpdateExecutor.cpp:61] Update vertice time: 488us
I20250122 11:38:26.808459 984381 ThriftClientManager-inl.h:47] Getting a client to "ip7":9779
I20250122 11:38:26.808629 984381 AsyncSocket.cpp:2711] this=0x7f1cb7c13800, AsyncSocket::handleRead() got 60 bytes
I20250122 11:38:26.808640 984381 StorageClientBase-inl.h:186] Failure! Failed part 57, failed part -3043
I20250122 11:38:26.808656 984342 UpdateExecutor.cpp:61] Update vertice time: 227us
I20250122 11:38:26.808722 984382 ThriftClientManager-inl.h:47] Getting a client to "ip5":9779
I20250122 11:38:27.062273 984327 AsyncSocket.cpp:2711] this=0x7f1cd322d000, AsyncSocket::handleRead() got 107 bytes
I20250122 11:38:27.062294 984327 HTTPSession.cpp:690] processing new msg streamID=62294 proto=http/1.1, UA=Go-http-client/1.1, downstream=ip1:42874, ip7:19669=local
I20250122 11:38:27.062305 984327 HTTP2PriorityQueue.cpp:512] Adding id=62294 with parent=0 and weight=16
I20250122 11:38:27.062319 984327 HTTPSession.cpp:839] processing ingress headers complete for proto=http/1.1, UA=Go-http-client/1.1, downstream=ip1:42874, ip7:19669=local, streamID=62294
I20250122 11:38:27.062332 984327 HTTPSession.cpp:980] processing ingress message complete for proto=http/1.1, UA=Go-http-client/1.1, downstream=ip1:42874, ip7:19669=local, streamID=62294
I20250122 11:38:27.062336 984327 HTTPTransaction.cpp:503] ingress EOM on proto=http/1.1, UA=Go-http-client/1.1, downstream=ip1:42874, ip7:19669=local, streamID=62294
I20250122 11:38:27.062338 984326 AsyncSocket.cpp:2711] this=0x7f1cd4035000, AsyncSocket::handleRead() got 106 bytes
I20250122 11:38:27.062353 984327 HTTPSession.cpp:1591] proto=http/1.1, UA=Go-http-client/1.1, downstream=ip1:42874, ip7:19669=local sending headers, size=0, uncompressedSize=100
I20250122 11:38:27.062358 984326 HTTPSession.cpp:690] processing new msg streamID=62134 proto=http/1.1, UA=Go-http-client/1.1, downstream=ip1:42870, ip7:19669=local
I20250122 11:38:27.062376 984327 HTTPSessionBase.cpp:147] notifyEgressBodyBuffered pwsd=45
I20250122 11:38:27.062381 984326 HTTP2PriorityQueue.cpp:512] Adding id=62134 with parent=0 and weight=16
I20250122 11:38:27.062381 984327 HTTPTransaction.cpp:1331] Queued egress EOM on proto=http/1.1, UA=Go-http-client/1.1, downstream=ip1:42874, ip7:19669=local, streamID=62294
I20250122 11:38:27.062397 984327 HTTPTransaction.cpp:1519] transaction already egress complete, not updating pause state proto=http/1.1, UA=Go-http-client/1.1, downstream=ip1:42874, ip7:19669=local, streamID=62294
I20250122 11:38:27.062402 984326 HTTPSession.cpp:839] processing ingress headers complete for proto=http/1.1, UA=Go-http-client/1.1, downstream=ip1:42870, ip7:19669=local, streamID=62134
I20250122 11:38:27.062405 984327 HTTPSession.cpp:2104] proto=http/1.1, UA=Go-http-client/1.1, downstream=ip1:42874, ip7:19669=local egressing txnID=62294 allowed=65536
I20250122 11:38:27.062417 984326 HTTPSession.cpp:980] processing ingress message complete for proto=http/1.1, UA=Go-http-client/1.1, downstream=ip1:42870, ip7:19669=local, streamID=62134
I20250122 11:38:27.062443 984326 HTTPTransaction.cpp:503] ingress EOM on proto=http/1.1, UA=Go-http-client/1.1, downstream=ip1:42870, ip7:19669=local, streamID=62134
I20250122 11:38:27.062435 984327 HTTPTransaction.cpp:1247] Sending 45 bytes of body. eom=yes send_window is None trailers=no proto=http/1.1, UA=Go-http-client/1.1, downstream=ip1:42874, ip7:19669=local, streamID=62294
I20250122 11:38:27.062455 984327 HTTPSessionBase.cpp:147] notifyEgressBodyBuffered pwsd=-45
I20250122 11:38:27.062460 984327 HTTPSessionBase.cpp:147] notifyEgressBodyBuffered pwsd=-45
I20250122 11:38:27.062463 984327 HTTPTransaction.cpp:1519] transaction already egress complete, not updating pause state proto=http/1.1, UA=Go-http-client/1.1, downstream=ip1:42874, ip7:19669=local, streamID=62294
I20250122 11:38:27.062467 984327 HTTPSession.cpp:2211] proto=http/1.1, UA=Go-http-client/1.1, downstream=ip1:42874, ip7:19669=local writing 145, activeWrites=1 cork:0 timestampTx:0 timestampAck:0
I20250122 11:38:27.062479 984327 HTTPTransaction.cpp:151] destroying transaction proto=http/1.1, UA=Go-http-client/1.1, downstream=ip1:42874, ip7:19669=local, streamID=62294
I20250122 11:38:27.062482 984327 HTTPSession.cpp:1886] proto=http/1.1, UA=Go-http-client/1.1, downstream=ip1:42874, ip7:19669=local removing streamID=62294, liveTransactions was 1
I20250122 11:38:27.062726 984326 HTTPSession.cpp:1591] proto=http/1.1, UA=Go-http-client/1.1, downstream=ip1:42870, ip7:19669=local sending headers, size=0, uncompressedSize=103
I20250122 11:38:27.062733 984326 HTTPSessionBase.cpp:147] notifyEgressBodyBuffered pwsd=13390
I20250122 11:38:27.062737 984326 HTTPTransaction.cpp:1331] Queued egress EOM on proto=http/1.1, UA=Go-http-client/1.1, downstream=ip1:42870, ip7:19669=local, streamID=62134
I20250122 11:38:27.062740 984326 HTTPTransaction.cpp:1519] transaction already egress complete, not updating pause state proto=http/1.1, UA=Go-http-client/1.1, downstream=ip1:42870, ip7:19669=local, streamID=62134
I20250122 11:38:27.062765 984326 HTTPSession.cpp:2104] proto=http/1.1, UA=Go-http-client/1.1, downstream=ip1:42870, ip7:19669=local egressing txnID=62134 allowed=65536
I20250122 11:38:27.062769 984326 HTTPTransaction.cpp:1247] Sending 13390 bytes of body. eom=yes send_window is None trailers=no proto=http/1.1, UA=Go-http-client/1.1, downstream=ip1:42870, ip7:19669=local, streamID=62134
I20250122 11:38:27.062775 984326 HTTPSessionBase.cpp:147] notifyEgressBodyBuffered pwsd=-13390
I20250122 11:38:27.062779 984326 HTTPSessionBase.cpp:147] notifyEgressBodyBuffered pwsd=-13390
I20250122 11:38:27.062783 984326 HTTPTransaction.cpp:1519] transaction already egress complete, not updating pause state proto=http/1.1, UA=Go-http-client/1.1, downstream=ip1:42870, ip7:19669=local, streamID=62134
I20250122 11:38:27.062786 984326 HTTPSession.cpp:2211] proto=http/1.1, UA=Go-http-client/1.1, downstream=ip1:42870, ip7:19669=local writing 13493, activeWrites=1 cork:0 timestampTx:0 timestampAck:0
I20250122 11:38:27.062801 984326 HTTPTransaction.cpp:151] destroying transaction proto=http/1.1, UA=Go-http-client/1.1, downstream=ip1:42870, ip7:19669=local, streamID=62134
I20250122 11:38:27.062806 984326 HTTPSession.cpp:1886] proto=http/1.1, UA=Go-http-client/1.1, downstream=ip1:42870, ip7:19669=local removing streamID=62134, liveTransactions was 1
I20250122 11:38:27.090683 984381 AsyncSocket.cpp:2711] this=0x7f1cb7caf800, AsyncSocket::handleRead() got 0 bytes
I20250122 11:38:27.090698 984381 Cpp2Connection.cpp:638] Channel client_ip:36296 closed: apache::thrift::transport::TTransportException: Channel Closed
I20250122 11:38:27.090709 984381 Acceptor.cpp:476] Acceptor=0x7f1ca4037428 onEmpty()
I20250122 11:38:27.090713 984381 Cpp2Connection.cpp:179] Task killed due to channel close: client_ip:36296
I20250122 11:38:27.091784 984380 AsyncSocket.cpp:2711] this=0x7f1cb8a15800, AsyncSocket::handleRead() got 13 bytes
I20250122 11:38:27.091799 984380 Acceptor.cpp:476] Acceptor=0x7f1ca4036f28 onEmpty()
I20250122 11:38:27.091809 984380 AsyncSocket.cpp:2711] this=0x7f1cb8a15800, AsyncSocket::handleRead() got 13 bytes
I20250122 11:38:27.091813 984380 Acceptor.cpp:476] Acceptor=0x7f1ca4036f28 onEmpty()
I20250122 11:38:27.091817 984380 Cpp2Worker.cpp:143] Cpp2Worker: Creating connection for socket 436
I20250122 11:38:27.091837 984380 Cpp2Worker.cpp:152] Cpp2Worker: created connection for socket 436
I20250122 11:38:27.091842 984380 AsyncSocket.cpp:2711] this=0x7f1cb8a15800, AsyncSocket::handleRead() got 38 bytes
I20250122 11:38:27.091861 984380 AsyncSocket.cpp:2711] this=0x7f1cb8a15800, AsyncSocket::handleRead() got -2 bytes
I20250122 11:38:27.092993 984380 AsyncSocket.cpp:2711] this=0x7f1cb8a15800, AsyncSocket::handleRead() got 39 bytes
I20250122 11:38:27.093016 984380 AsyncSocket.cpp:2711] this=0x7f1cb8a15800, AsyncSocket::handleRead() got 0 bytes
I20250122 11:38:27.093020 984354 GraphService.cpp:142] Sign out session 1737514882128504
I20250122 11:38:27.093021 984380 Cpp2Connection.cpp:638] Channel client_ip:17444 closed: apache::thrift::transport::TTransportException: Channel Closed
I20250122 11:38:27.093039 984380 Acceptor.cpp:476] Acceptor=0x7f1ca4036f28 onEmpty()
I20250122 11:38:27.093042 984380 Cpp2Connection.cpp:179] Task killed due to channel close: client_ip:17444
I20250122 11:38:27.093056 984383 ThriftClientManager-inl.h:47] Getting a client to "ip3":9559
I20250122 11:38:27.093066 984383 MetaClient.cpp:730] Send request to meta "ip3":9559
I20250122 11:38:27.094909 984383 AsyncSocket.cpp:2711] this=0x7f1cb6010800, AsyncSocket::handleRead() got 45 bytes
I20250122 11:38:27.222981 984377 AsyncSocket.cpp:2711] this=0x7f1cbb416c00, AsyncSocket::handleRead() got 62 bytes
I20250122 11:38:27.223007 984377 StorageClientBase-inl.h:186] Failure! Failed part 89, failed part -3043
I20250122 11:38:27.223030 984354 UpdateExecutor.cpp:113] Update edge time: 1015324us
I20250122 11:38:27.223088 984384 ThriftClientManager-inl.h:47] Getting a client to "ip2":9779
I20250122 11:38:27.223147 984390 AsyncSocket.cpp:2711] this=0x7f1cafc11000, AsyncSocket::handleRead() got 180 bytes
I20250122 11:38:27.223189 984382 AsyncSocket.cpp:2711] this=0x7f1cb6e13800, AsyncSocket::handleRead() got 125 bytes
I20250122 11:38:27.223232 984337 UpdateExecutor.cpp:61] Update vertice time: 414687us
I20250122 11:38:27.223295 984385 ThriftClientManager-inl.h:47] Getting a client to "ip1":9779
I20250122 11:38:27.223307 984384 AsyncSocket.cpp:2711] this=0x7f1cb520f400, AsyncSocket::handleRead() got 62 bytes
I20250122 11:38:27.223331 984384 StorageClientBase-inl.h:186] Failure! Failed part 125, failed part -3043
I20250122 11:38:27.223335 984350 Executor.cpp:597] Execution is being killed. session: 1737514882128504ep: 1782211query: match (c:tag1)
where id(c)=='E0mhlhkIu0AMuKqmG'
match (c)<-[:edge1]->(m:tag2)-[:goods]->(o:info)
return count(distinct case when o.info.ob_status in [0,2] then m.tag2.cd else null end) as v1
I20250122 11:38:27.223352 984351 UpdateExecutor.cpp:113] Update edge time: 292us
E20250122 11:38:27.223387 984363 QueryInstance.cpp:151] Execution had been killed, query: match (c:tag1)
where id(c)=='E0mhlhkIu0AMuKqmG'
match (c)<-[:edge1]->(m:tag2)-[:goods]->(o:info)
return count(distinct case when o.info.ob_status in [0,2] then m.tag2.cd else null end) as v1
I20250122 11:38:27.223416 984363 ClientSession.cpp:52] Delete query, epId: 1782211
上述超时查询通过studio再次调用正常返回的日志
I20250122 11:43:19.273694 1655575 ClientSession.cpp:43] Add query: match (c:tag1) where id(c)=='E0mhlhkIu0AMuKqmG' match (c)<-[:edge1]->(m:tag2)-[:goods]->(o:info) return count(distinct case when o.info.ob_status in [0,2] then m.tag2.cd else null end) as v1, epId: 2447077
I20250122 11:43:19.273706 1655575 QueryInstance.cpp:80] Parsing query: match (c:tag1) where id(c)=='E0mhlhkIu0AMuKqmG' match (c)<-[:edge1]->(m:tag2)-[:goods]->(o:info) return count(distinct case when o.info.ob_status in [0,2] then m.tag2.cd else null end) as v1
I20250122 11:43:19.273756 1655575 Symbols.cpp:48] New variable for: __Start_0
I20250122 11:43:19.273759 1655575 PlanNode.cpp:27] New variable: __Start_0
I20250122 11:43:19.273763 1655575 Validator.cpp:350] Space chosen, name: graph_v1 id: 2
I20250122 11:43:19.273787 1655575 Symbols.cpp:48] New variable for: __VAR_0
I20250122 11:43:19.273792 1655575 AnonVarGenerator.h:28] Build anon var: __VAR_0
I20250122 11:43:19.273794 1655575 Symbols.cpp:48] New variable for: __VAR_1
I20250122 11:43:19.273797 1655575 AnonVarGenerator.h:28] Build anon var: __VAR_1
I20250122 11:43:19.273821 1655575 Symbols.cpp:48] New variable for: __VAR_2
I20250122 11:43:19.273824 1655575 AnonVarGenerator.h:28] Build anon var: __VAR_2
I20250122 11:43:19.273829 1655575 Symbols.cpp:48] New variable for: __PassThrough_1
I20250122 11:43:19.273831 1655575 PlanNode.cpp:27] New variable: __PassThrough_1
I20250122 11:43:19.273835 1655575 Symbols.cpp:48] New variable for: __Dedup_2
I20250122 11:43:19.273838 1655575 PlanNode.cpp:27] New variable: __Dedup_2
I20250122 11:43:19.273842 1655575 MatchPathPlanner.cpp:126] Find starts: 0, Pattern has 0 edges, root: __Dedup_2, colNames: _vid
I20250122 11:43:19.273845 1655575 Symbols.cpp:48] New variable for: __Start_3
I20250122 11:43:19.273847 1655575 PlanNode.cpp:27] New variable: __Start_3
I20250122 11:43:19.273851 1655575 Symbols.cpp:48] New variable for: __AppendVertices_4
I20250122 11:43:19.273854 1655575 PlanNode.cpp:27] New variable: __AppendVertices_4
I20250122 11:43:19.273896 1655575 Symbols.cpp:48] New variable for: __Project_5
I20250122 11:43:19.273900 1655575 PlanNode.cpp:27] New variable: __Project_5
I20250122 11:43:19.273908 1655575 Symbols.cpp:48] New variable for: __Argument_6
I20250122 11:43:19.273911 1655575 PlanNode.cpp:27] New variable: __Argument_6
I20250122 11:43:19.273916 1655575 MatchPathPlanner.cpp:126] Find starts: 0, Pattern has 2 edges, root: __Argument_6, colNames: c
I20250122 11:43:19.273918 1655575 Symbols.cpp:48] New variable for: __Traverse_7
I20250122 11:43:19.273921 1655575 PlanNode.cpp:27] New variable: __Traverse_7
I20250122 11:43:19.273957 1655575 ServerBasedSchemaManager.cpp:68] Get Edge Schema Space 2, EdgeType 108, Version -1
I20250122 11:43:19.273962 1655575 Symbols.cpp:48] New variable for: __Traverse_8
I20250122 11:43:19.273965 1655575 PlanNode.cpp:27] New variable: __Traverse_8
I20250122 11:43:19.273998 1655575 ServerBasedSchemaManager.cpp:68] Get Edge Schema Space 2, EdgeType 92, Version -1
I20250122 11:43:19.274001 1655575 ServerBasedSchemaManager.cpp:68] Get Edge Schema Space 2, EdgeType 104, Version -1
I20250122 11:43:19.274005 1655575 Symbols.cpp:48] New variable for: __AppendVertices_9
I20250122 11:43:19.274008 1655575 PlanNode.cpp:27] New variable: __AppendVertices_9
I20250122 11:43:19.274046 1655575 Symbols.cpp:48] New variable for: __Project_10
I20250122 11:43:19.274049 1655575 PlanNode.cpp:27] New variable: __Project_10
I20250122 11:43:19.274053 1655575 Symbols.cpp:48] New variable for: __HashInnerJoin_11
I20250122 11:43:19.274056 1655575 PlanNode.cpp:27] New variable: __HashInnerJoin_11
I20250122 11:43:19.274062 1655575 Symbols.cpp:48] New variable for: __Aggregate_12
I20250122 11:43:19.274065 1655575 PlanNode.cpp:27] New variable: __Aggregate_12
I20250122 11:43:19.274068 1655575 ReturnClausePlanner.cpp:52] return root: __Aggregate_12 colNames: v1
I20250122 11:43:19.274071 1655575 MatchPlanner.cpp:172] root(Aggregate_12): __Aggregate_12, tail(Start_3): __Start_3
I20250122 11:43:19.274075 1655575 Validator.cpp:409] root: Aggregate tail: Start
I20250122 11:43:19.274077 1655575 Validator.cpp:409] root: Aggregate tail: Start
I20250122 11:43:19.274116 1655575 Symbols.cpp:48] New variable for: __AppendVertices_13
I20250122 11:43:19.274119 1655575 PlanNode.cpp:27] New variable: __AppendVertices_13
I20250122 11:43:19.274169 1655575 Symbols.cpp:48] New variable for: __AppendVertices_14
I20250122 11:43:19.274171 1655575 PlanNode.cpp:27] New variable: __AppendVertices_14
I20250122 11:43:19.274189 1655575 Symbols.cpp:48] New variable for: __Traverse_15
I20250122 11:43:19.274194 1655575 PlanNode.cpp:27] New variable: __Traverse_15
I20250122 11:43:19.274220 1655575 Symbols.cpp:48] New variable for: __AppendVertices_16
I20250122 11:43:19.274224 1655575 PlanNode.cpp:27] New variable: __AppendVertices_16
I20250122 11:43:19.274664 1655608 ThriftClientManager-inl.h:47] Getting a client to "ip1":9779
I20250122 11:43:19.274828 1655608 AsyncSocket.cpp:2711] this=0x7f1178a0f400, AsyncSocket::handleRead() got 108 bytes
I20250122 11:43:19.274947 1655610 ThriftClientManager-inl.h:47] Getting a client to "ip1":9779
I20250122 11:43:19.275187 1655610 AsyncSocket.cpp:2711] this=0x7f1176e1a000, AsyncSocket::handleRead() got 323 bytes
I20250122 11:43:19.275333 1655612 ThriftClientManager-inl.h:47] Getting a client to "ip3":9779
I20250122 11:43:19.275346 1655613 ThriftClientManager-inl.h:47] Getting a client to "ip1":9779
I20250122 11:43:19.275363 1655615 ThriftClientManager-inl.h:47] Getting a client to "ip7":9779
I20250122 11:43:19.275352 1655614 ThriftClientManager-inl.h:47] Getting a client to "ip5":9779
I20250122 11:43:19.275650 1655615 AsyncSocket.cpp:2711] this=0x7f1172818c00, AsyncSocket::handleRead() got 634 bytes
I20250122 11:43:19.275678 1655613 AsyncSocket.cpp:2711] this=0x7f1174419c00, AsyncSocket::handleRead() got 424 bytes
I20250122 11:43:19.275682 1655612 AsyncSocket.cpp:2711] this=0x7f1175219800, AsyncSocket::handleRead() got 218 bytes
I20250122 11:43:19.275696 1655614 AsyncSocket.cpp:2711] this=0x7f1173613000, AsyncSocket::handleRead() got 179 bytes
I20250122 11:43:19.275956 1655616 ThriftClientManager-inl.h:47] Getting a client to "ip2":9779
I20250122 11:43:19.275970 1655618 ThriftClientManager-inl.h:47] Getting a client to "ip1":9779
I20250122 11:43:19.275960 1655617 ThriftClientManager-inl.h:47] Getting a client to "ip5":9779
I20250122 11:43:19.275985 1655619 ThriftClientManager-inl.h:47] Getting a client to "ip7":9779
I20250122 11:43:19.276001 1655585 ThriftClientManager-inl.h:47] Getting a client to "ip6":9779
I20250122 11:43:19.275993 1655620 ThriftClientManager-inl.h:47] Getting a client to "ip3":9779
I20250122 11:43:19.276015 1655586 ThriftClientManager-inl.h:47] Getting a client to "ip4":9779
I20250122 11:43:19.276479 1655618 AsyncSocket.cpp:2711] this=0x7f116fe1a400, AsyncSocket::handleRead() got 116 bytes
I20250122 11:43:19.276525 1655616 AsyncSocket.cpp:2711] this=0x7f1171a19c00, AsyncSocket::handleRead() got 114 bytes
I20250122 11:43:19.276542 1655617 AsyncSocket.cpp:2711] this=0x7f1170c19400, AsyncSocket::handleRead() got 218 bytes
I20250122 11:43:19.276610 1655619 AsyncSocket.cpp:2711] this=0x7f116f018400, AsyncSocket::handleRead() got 252 bytes
I20250122 11:43:19.276623 1655586 AsyncSocket.cpp:2711] this=0x7f118c614000, AsyncSocket::handleRead() got 149 bytes
I20250122 11:43:19.276674 1655620 AsyncSocket.cpp:2711] this=0x7f116e219000, AsyncSocket::handleRead() got 252 bytes
I20250122 11:43:19.276948 1655585 AsyncSocket.cpp:2711] this=0x7f118d415c00, AsyncSocket::handleRead() got 150 bytes
I20250122 11:43:19.277141 1655549 QueryInstance.cpp:128] Finish query: match (c:tag1) where id(c)=='E0mhlhkIu0AMuKqmG' match (c)<-[:edge1]->(m:tag2)-[:goods]->(o:info) return count(distinct case when o.info.ob_status in [0,2] then m.tag2.cd else null end) as v1
I20250122 11:43:19.277161 1655549 ClientSession.cpp:52] Delete query, epId: 2447077
日志上看,超时查询相比正常查询日志中间多了一个插入语句