fix CR

analytic_engine/src/row_iter/chain.rs

@@ -163,7 +163,7 @@ impl<'a> Builder<'a> {
             request_id: self.config.request_id,
             schema: self.config.projected_schema.to_record_schema_with_key(),
             streams,
-            _ssts: self.ssts,
+            ssts: self.ssts,
             next_stream_idx: 0,
             inited: false,
             metrics: Metrics::new(self.memtables.len(), total_sst_streams),
@@ -226,7 +226,8 @@ pub struct ChainIterator {
     schema: RecordSchemaWithKey,
     streams: Vec<SequencedRecordBatchStream>,
     /// ssts are kept here to avoid them from being purged.
-    _ssts: Vec<Vec<FileHandle>>,
+    #[allow(dead_code)]
+    ssts: Vec<Vec<FileHandle>>,
     /// The range of the index is [0, streams.len()] and the iterator is
     /// exhausted if it reaches `streams.len()`.
     next_stream_idx: usize,
@@ -325,7 +326,7 @@ mod tests {
             request_id: RequestId::next_id(),
             schema: schema.to_record_schema_with_key(),
             streams,
-            _ssts: Vec::new(),
+            ssts: Vec::new(),
             next_stream_idx: 0,
             inited: false,
             metrics: Metrics::new(0, 0),

analytic_engine/src/row_iter/merge.rs

@@ -621,7 +621,8 @@ pub struct MergeIterator {
     record_batch_builder: RecordBatchWithKeyBuilder,
     origin_streams: Vec<SequencedRecordBatchStream>,
     /// ssts are kept here to avoid them from being purged.
-    _ssts: Vec<Vec<FileHandle>>,
+    #[allow(dead_code)]
+    ssts: Vec<Vec<FileHandle>>,
     /// Any [BufferedStream] in the hot heap is not empty.
     hot: BinaryHeap<HeapBufferedStream>,
     /// Any [BufferedStream] in the cold heap is not empty.
@@ -651,7 +652,7 @@ impl MergeIterator {
             request_id,
             inited: false,
             schema,
-            _ssts: ssts,
+            ssts,
             record_batch_builder,
             origin_streams: streams,
             hot: BinaryHeap::with_capacity(heap_cap),