test: add query result

GreptimeTeam · Feb 23, 2024 · 5d327c0 · 5d327c0
1 parent 1536a02
commit 5d327c0
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/tests-integration/tests/region_migration.rs b/tests-integration/tests/region_migration.rs
@@ -868,6 +868,8 @@ async fn find_region_distribution_by_sql(cluster: &GreptimeDbCluster) -> RegionD
 
     let recordbatches = RecordBatches::try_collect(stream).await.unwrap();
 
+    info!("SQL result:\n {}", recordbatches.pretty_print().unwrap());
+
     let mut distribution = RegionDistribution::new();
 
     for batch in recordbatches.take() {
@@ -911,6 +913,8 @@ async fn trigger_migration_by_sql(
 
     let recordbatches = RecordBatches::try_collect(stream).await.unwrap();
 
+    info!("SQL result:\n {}", recordbatches.pretty_print().unwrap());
+
     let Value::String(procedure_id) = recordbatches.take()[0].column(0).get(0) else {
         unreachable!();
     };
@@ -932,6 +936,8 @@ async fn query_procedure_by_sql(instance: &Arc<Instance>, pid: &str) -> String {
 
     let recordbatches = RecordBatches::try_collect(stream).await.unwrap();
 
+    info!("SQL result:\n {}", recordbatches.pretty_print().unwrap());
+
     let Value::String(state) = recordbatches.take()[0].column(0).get(0) else {
         unreachable!();
     };