fix core

liuneng1994 · Sep 27, 2023 · 0b91cac · 0b91cac
1 parent da16ffb
commit 0b91cac
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/Processors/Transforms/JoiningTransform.cpp b/src/Processors/Transforms/JoiningTransform.cpp
@@ -132,7 +132,7 @@ void JoiningTransform::work()
         // Process the next chunk after all the current result set is output.
         if (!join->supportStreamJoin() || !blocks || blocks->isFinished())
             transform(input_chunk);
-        if (join->supportStreamJoin() && !on_totals)
+        if (blocks)
         {
             auto block = blocks->next();
             output_chunk.setColumns(block.getColumns(), block.rows());