fix bucket_seq_to_instance_index

924060929 · Oct 17, 2024 · 775c14c · 775c14c
1 parent a1ecef8
commit 775c14c
Showing 1 changed file with 1 addition and 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
@@ -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();