remove dbg

jiacai2050 · Nov 20, 2024 · e065ba7 · e065ba7
1 parent fa22563
commit e065ba7
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git 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<RecordBatch>;
 
     fn poll_next(mut self: Pin<&mut Self>, ctx: &mut Context) -> Poll<Option<Self::Item>> {
-        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
@@ -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))