Wang Xixu has posted comments on this change. ( http://gerrit.cloudera.org:8080/18846 )
Change subject: [Client] Add request id to trace the whole query process ...................................................................... Patch Set 18: (12 comments) > Patch Set 17: > > (12 comments) http://gerrit.cloudera.org:8080/#/c/18846/17/src/kudu/client/client-test.cc File src/kudu/client/client-test.cc: http://gerrit.cloudera.org:8080/#/c/18846/17/src/kudu/client/client-test.cc@1139 PS17, Line 1139: DoTestScanWithStringPredicate(); > Need to check the request id is occured in the logs. It is difficult to get the console output to check the request id. http://gerrit.cloudera.org:8080/#/c/18846/17/src/kudu/client/client.h File src/kudu/client/client.h: http://gerrit.cloudera.org:8080/#/c/18846/17/src/kudu/client/client.h@2790 PS17, Line 2790: C > nit: Set Done http://gerrit.cloudera.org:8080/#/c/18846/17/src/kudu/client/client.h@2792 PS17, Line 2792: tedColu > nit: request_id Done http://gerrit.cloudera.org:8080/#/c/18846/17/src/kudu/client/client.h@2793 PS17, Line 2793: > debugging Done http://gerrit.cloudera.org:8080/#/c/18846/17/src/kudu/client/client.h@3353 PS17, Line 3353: able me > nit: request_id Done http://gerrit.cloudera.org:8080/#/c/18846/17/src/kudu/client/client.h@3354 PS17, Line 3354: > nit: debugging Done http://gerrit.cloudera.org:8080/#/c/18846/17/src/kudu/client/client.cc File src/kudu/client/client.cc: http://gerrit.cloudera.org:8080/#/c/18846/17/src/kudu/client/client.cc@1735 PS17, Line 1735: } : : return Status::OK(); > Would it be better to use the random id in a upper layer, and set it regard The upper layer of KuduScanner is KuduClient. A KuduClient may send more than one query. But A KuduScanner only represents a query. http://gerrit.cloudera.org:8080/#/c/18846/17/src/kudu/client/scan_token-test.cc File src/kudu/client/scan_token-test.cc: http://gerrit.cloudera.org:8080/#/c/18846/17/src/kudu/client/scan_token-test.cc@450 PS17, Line 450: // Create schema : KuduSchema schema; : { : KuduSchemaBuilder builder; : builder.AddColumn("col")->NotNull()->Type(KuduColumnSchema::INT64)->PrimaryKey(); : ASSERT_OK(builder.Build(&schema)); : } : : // Create table : shared_ptr<KuduTable> table; : { : unique_ptr<KuduPartialRow> split(schema.NewRow()); : ASSERT_OK(split->SetInt64("col", 0)); : unique_ptr<KuduTableCreator> table_creator(client_->NewTableCreator()); : #pragma GCC diagnostic push : #pragma GCC diagnostic ignored "-Wdeprecated-declarations" : ASSERT_OK(table_creator->table_name("table") : .schema(&schema) : .add_hash_partitions({ "col" }, 4) : .split_rows({ split.release() }) : .num_replicas(1) : .Create()); : #pragma GCC diagnostic pop : ASSERT_OK(client_->OpenTable("table", &table)); : } : // Create session : shared_ptr<KuduSession> session = client_->NewSession(); : session->SetTimeoutMillis(10000); : ASSERT_OK(session->SetFlushMode(KuduSession::AUTO_FLUSH_BACKGROUND)); : : // Insert rows : for (int i = 0; i < 100; i++) { : unique_ptr<KuduInsert> insert(table->NewInsert()); : ASSERT_OK(insert->mutable_row()->SetInt64("col", i)); : ASSERT_OK(session->Apply(insert.release())); : } : ASSERT_OK(session->Flush()); : : > How about use TestWorkload to simplify the code? No. The follow code need to use shared_ptr<KuduTable> table to execute a query. http://gerrit.cloudera.org:8080/#/c/18846/17/src/kudu/client/scan_token-test.cc@494 PS17, Line 494: ASSERT_OK(builder.Build(&tokens)); > Not set it and keep the default value for it. Done http://gerrit.cloudera.org:8080/#/c/18846/17/src/kudu/client/scan_token-test.cc@502 PS17, Line 502: // Scan without request id. > What does it mean? Is it related to what you want to test? Done http://gerrit.cloudera.org:8080/#/c/18846/17/src/kudu/client/scan_token-test.cc@510 PS17, Line 510: ASSERT_OK(IntoUniqueScanner(client_.get( > Not set it and keep the default value for it. Done http://gerrit.cloudera.org:8080/#/c/18846/17/src/kudu/tserver/tablet_server-test.cc File src/kudu/tserver/tablet_server-test.cc: http://gerrit.cloudera.org:8080/#/c/18846/17/src/kudu/tserver/tablet_server-test.cc@2887 PS17, Line 2887: ASSERT_FALSE(resp.has_error()); > Same, missing testing request_id occurred. resp will not return the request id. The request id will be printed in log. It is difficult to verify it. The test case checks a query with request id will be executed without any error. -- To view, visit http://gerrit.cloudera.org:8080/18846 To unsubscribe, visit http://gerrit.cloudera.org:8080/settings Gerrit-Project: kudu Gerrit-Branch: master Gerrit-MessageType: comment Gerrit-Change-Id: I9dbae801596726fec1c85ee547128da3179345d9 Gerrit-Change-Number: 18846 Gerrit-PatchSet: 18 Gerrit-Owner: Wang Xixu <[email protected]> Gerrit-Reviewer: Abhishek Chennaka <[email protected]> Gerrit-Reviewer: Jian Zhang <[email protected]> Gerrit-Reviewer: Kudu Jenkins (120) Gerrit-Reviewer: Mahesh Reddy <[email protected]> Gerrit-Reviewer: Tidy Bot (241) Gerrit-Reviewer: Wang Xixu <[email protected]> Gerrit-Reviewer: Yifan Zhang <[email protected]> Gerrit-Reviewer: Yingchun Lai <[email protected]> Gerrit-Reviewer: Yuqi Du <[email protected]> Gerrit-Comment-Date: Wed, 19 Oct 2022 03:35:02 +0000 Gerrit-HasComments: Yes
