From 13f20b5a40dc652a81ddde22b04dd0af796f5be7 Mon Sep 17 00:00:00 2001
From: discord9 <discord9@163.com>
Date: Wed, 9 Jul 2025 16:14:00 +0800
Subject: [PATCH] add logging to figure test failure

Signed-off-by: discord9 <discord9@163.com>
---
 src/query/src/dist_plan/merge_scan.rs | 11 +++++++++++
 1 file changed, 11 insertions(+)

diff --git a/src/query/src/dist_plan/merge_scan.rs b/src/query/src/dist_plan/merge_scan.rs
index c98206dbc5..826bdff6ee 100644
--- a/src/query/src/dist_plan/merge_scan.rs
+++ b/src/query/src/dist_plan/merge_scan.rs
@@ -325,6 +325,17 @@ impl MergeScanExec {
                     "Merge scan stop poll stream, partition: {}, region_id: {}, poll_duration: {:?}, first_consume: {}, do_get_cost: {:?}",
                     partition, region_id, poll_duration, metric.first_consume_time(), do_get_cost
                 );
+                // TODO(discord9): rm this debug log after debugging
+                common_telemetry::debug!(
+                    "All regions: {:?}, scan regions with skip partition: {:?}",
+                    regions,
+                    regions
+                        .iter()
+                        .skip(partition)
+                        .step_by(target_partition)
+                        .copied()
+                        .collect::<Vec<_>>()
+                );
 
                 // process metrics after all data is drained.
                 if let Some(metrics) = stream.metrics() {