fix full join failed

liuneng1994 · Sep 27, 2023 · da16ffb · da16ffb
1 parent 4bb08b4
commit da16ffb
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/src/Processors/Transforms/JoiningTransform.cpp b/src/Processors/Transforms/JoiningTransform.cpp
@@ -210,7 +210,10 @@ void JoiningTransform::transform(Chunk & chunk)
     else
         block = readExecute(chunk);
     auto num_rows = block.rows();
-    chunk.setColumns(block.getColumns(), num_rows);
+    if (!join->supportStreamJoin() || on_totals)
+    {
+        chunk.setColumns(block.getColumns(), num_rows);
+    }
 }
 
 void JoiningTransform::joinBlock(Block & block, std::shared_ptr<ExtraBlock> & not_processed_block)