diff --git a/core/trino-main/src/main/java/io/trino/operator/join/JoinUtils.java b/core/trino-main/src/main/java/io/trino/operator/join/JoinUtils.java
index 1953275b97cb..ebc43665c4fc 100644
--- a/core/trino-main/src/main/java/io/trino/operator/join/JoinUtils.java
+++ b/core/trino-main/src/main/java/io/trino/operator/join/JoinUtils.java
@@ -67,7 +67,7 @@ public static boolean isBuildSideReplicated(PlanNode node)
                             planNode -> planNode instanceof ProjectNode ||
                                     isLocalRepartitionExchange(planNode) ||
                                     isLocalGatherExchange(planNode))  // used in cross join case
-                    .where(joinNode -> isRemoteReplicatedExchange(joinNode) || isRemoteReplicatedSourceNode(joinNode))
+                    .where(planNode -> isRemoteReplicatedExchange(planNode) || isRemoteReplicatedSourceNode(planNode))
                     .matches();
         }
         return PlanNodeSearcher.searchFrom(((SemiJoinNode) node).getFilteringSource())