From 775c14c269a955e607cb91cc390045f09ee0b797 Mon Sep 17 00:00:00 2001
From: 924060929 <924060929@qq.com>
Date: Thu, 17 Oct 2024 15:38:10 +0800
Subject: [PATCH] fix bucket_seq_to_instance_index

---
 .../java/org/apache/doris/qe/runtime/ThriftPlansBuilder.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/runtime/ThriftPlansBuilder.java b/fe/fe-core/src/main/java/org/apache/doris/qe/runtime/ThriftPlansBuilder.java
index ec7c83ceb71f63e..b18404fb9194311 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/qe/runtime/ThriftPlansBuilder.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/qe/runtime/ThriftPlansBuilder.java
@@ -510,7 +510,7 @@ private static void filterInstancesWhichReceiveDataFromRemote(
         Map<DataSink, List<AssignedJob>> sinkToDestInstances = firstInputPlan.getDestinations();
         for (Entry<DataSink, List<AssignedJob>> kv : sinkToDestInstances.entrySet()) {
             DataSink senderSink = kv.getKey();
-            if (senderSink.getExchNodeId() == linkNode.getId()) {
+            if (senderSink.getExchNodeId().asInt() == linkNode.getId().asInt()) {
                 Set<AssignedJob> destinations = Sets.newLinkedHashSet(kv.getValue());
                 Map<Long, AtomicInteger> backendIdToInstanceCount = Maps.newLinkedHashMap();
                 List<AssignedJob> instanceJobs = receivePlan.getInstanceJobs();