From e065ba7246d808fc82a03abc45aba21b2b5eb936 Mon Sep 17 00:00:00 2001 From: jiacai2050 Date: Wed, 20 Nov 2024 15:06:25 +0800 Subject: [PATCH] remove dbg --- horaedb/metric_engine/src/read.rs | 2 +- horaedb/metric_engine/src/storage.rs | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/horaedb/metric_engine/src/read.rs b/horaedb/metric_engine/src/read.rs index 6a530a6339..26564a1a53 100644 --- a/horaedb/metric_engine/src/read.rs +++ b/horaedb/metric_engine/src/read.rs @@ -306,7 +306,7 @@ impl Stream for MergeStream { type Item = DfResult; fn poll_next(mut self: Pin<&mut Self>, ctx: &mut Context) -> Poll> { - match dbg!(self.stream.poll_next_unpin(ctx)) { + match self.stream.poll_next_unpin(ctx) { Poll::Pending => Poll::Pending, Poll::Ready(None) => { let value = if let Some(mut pending) = self.pending_batch.take() { diff --git a/horaedb/metric_engine/src/storage.rs b/horaedb/metric_engine/src/storage.rs index 1887e4f674..0281608873 100644 --- a/horaedb/metric_engine/src/storage.rs +++ b/horaedb/metric_engine/src/storage.rs @@ -323,7 +323,7 @@ impl CloudObjectStorage { Arc::new(sort_exec), self.num_primary_keys, self.schema().fields.len() - 1, - 0, // TODO: value_idx + 0, // TODO: value_idx, not used now. Arc::new(LastValue::new()), ); Ok(Arc::new(merge_exec))