fix iterator invalidation (#654)

timeplus-io · Apr 10, 2024 · a9966a9 · a9966a9
1 parent 412bf88
commit a9966a9
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/src/Processors/Transforms/Streaming/WatermarkTransformWithSubstream.cpp b/src/Processors/Transforms/Streaming/WatermarkTransformWithSubstream.cpp
@@ -107,6 +107,8 @@ void WatermarkTransformWithSubstream::work()
     assert(output_iter == output_chunks.end());
     output_chunks.clear();
 
+    SCOPE_EXIT({ output_iter = output_chunks.begin(); });
+
     /// We will need clear input_chunk for next run
     Chunk process_chunk;
     process_chunk.swap(input_chunk);