fix unused pinned boxed fut

risingwavelabs · Nov 25, 2023 · 8412607 · 8412607
1 parent a3ea7c0
commit 8412607
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/stream/src/common/log_store_impl/kv_log_store/reader.rs b/src/stream/src/common/log_store_impl/kv_log_store/reader.rs
@@ -99,7 +99,7 @@ impl<S: StateStore> KvLogStoreReader<S> {
     ) -> LogStoreResult<Option<(ChunkId, StreamChunk, u64)>> {
         if let Some(future) = self.read_flushed_chunk_future.as_mut() {
             let result = future.await;
-            self.read_flushed_chunk_future
+            _ = self.read_flushed_chunk_future
                 .take()
                 .expect("future not None");
             Ok(Some(result?))