From cee316d0029f7fa55110a8f5c4d8f4078882a804 Mon Sep 17 00:00:00 2001
From: 924060929 <924060929@qq.com>
Date: Wed, 9 Oct 2024 20:56:14 +0800
Subject: [PATCH] share hash table

---
 .../doris/nereids/trees/plans/distribute/DistributePlanner.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/distribute/DistributePlanner.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/distribute/DistributePlanner.java
index 13e00eb69672f7e..747d06352356545 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/distribute/DistributePlanner.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/distribute/DistributePlanner.java
@@ -144,7 +144,7 @@ private List<AssignedJob> filterInstancesWhichCanReceiveDataFromRemote(
         if (useLocalShuffle) {
             return getFirstInstancePerShareScan(receiverPlan);
         } else if (enableShareHashTableForBroadcastJoin && linkNode.isRightChildOfBroadcastHashJoin()) {
-            return getFirstInstancePerShareScan(receiverPlan);
+            return getFirstInstancePerWorker(receiverPlan.getInstanceJobs());
         } else {
             return receiverPlan.getInstanceJobs();
         }