add logging to figure test failure

Signed-off-by: discord9 <discord9@163.com>
This commit is contained in:
discord9
2025-07-09 16:14:00 +08:00
parent 2b802e45f5
commit 13f20b5a40

View File

@@ -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() {