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