From 657f3e6318328dc0ae95f0ff23b865468a4f2678 Mon Sep 17 00:00:00 2001
From: Jerry Hu <mrhhsg@gmail.com>
Date: Thu, 29 Dec 2022 14:19:57 +0800
Subject: [PATCH] [fix](pipeline) disable sharing hashtable for broadcast join
 for pipeline engine (#15432)

---
 .../src/main/java/org/apache/doris/qe/SessionVariable.java   | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java b/fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java
index 2ba8a5cfe8..38abc038c3 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java
@@ -1326,7 +1326,10 @@ public class SessionVariable implements Serializable, Writable {
         tResult.setEnablePipelineEngine(enablePipelineEngine);
         tResult.setReturnObjectDataAsBinary(returnObjectDataAsBinary);
         tResult.setTrimTailingSpacesForExternalTableQuery(trimTailingSpacesForExternalTableQuery);
-        tResult.setEnableShareHashTableForBroadcastJoin(enableShareHashTableForBroadcastJoin);
+
+        // TODO: enable share hashtable for broadcast after switching completely to pipeline engine.
+        tResult.setEnableShareHashTableForBroadcastJoin(
+                enablePipelineEngine ? false : enableShareHashTableForBroadcastJoin);
 
         tResult.setBatchSize(batchSize);
         tResult.setDisableStreamPreaggregations(disableStreamPreaggregations);