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);