diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/parser/LogicalPlanBuilder.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/parser/LogicalPlanBuilder.java index f13cc8b69cb60a..0d4c6ea4bf6ba0 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/nereids/parser/LogicalPlanBuilder.java +++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/parser/LogicalPlanBuilder.java @@ -2773,6 +2773,7 @@ private LogicalPlan withJoinRelations(LogicalPlan input, RelationContext ctx) { } if (distributeHint.distributeType != DistributeType.NONE + && ConnectContext.get().getStatementContext() != null && !ConnectContext.get().getStatementContext().getHints().contains(distributeHint)) { ConnectContext.get().getStatementContext().addHint(distributeHint); }