diff --git a/tests-integration/tests/region_migration.rs b/tests-integration/tests/region_migration.rs index 9831eca35939..a62f49946424 100644 --- 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, 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!(); };