feat(format): replace state each deserialize

databendlabs · May 7, 2022 · 4f9a2e9 · 4f9a2e9
1 parent 036df85
commit 4f9a2e9
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/query/src/formats/format_csv.rs b/query/src/formats/format_csv.rs
@@ -182,6 +182,7 @@ impl InputFormat for CsvInputFormat {
             deserializers.push(data_type.create_deserializer(self.min_accepted_rows));
         }
 
+        let mut state = std::mem::replace(state, self.create_state());
         let state = state.as_any().downcast_mut::<CsvInputState>().unwrap();
         let cursor = Cursor::new(&state.memory);
         let reader: Box<dyn BufferRead> = Box::new(BufferReader::new(cursor));