fix

924060929 · Jun 19, 2024 · cbfb692 · cbfb692
1 parent 9ea1de6
commit cbfb692
Show file tree

Hide file tree

Showing 4 changed files with 5 additions and 2 deletions.
diff --git a/...e-core/src/main/java/org/apache/doris/nereids/trees/plans/distribute/DistributedPlan.java b/...e-core/src/main/java/org/apache/doris/nereids/trees/plans/distribute/DistributedPlan.java
@@ -42,6 +42,7 @@ public DistributedPlan withChildren(List<DistributedPlan> children) {
 
     public abstract String toString(int displayFragmentId);
 
+    /** toString */
     public static String toString(List<DistributedPlan> distributedPlansBottomToTop) {
         StringBuilder distributedPlanStringBuilder = new StringBuilder();
         int fragmentDisplayId = 0;

diff --git a/...in/java/org/apache/doris/nereids/worker/job/UnassignedGatherScanMultiRemoteTablesJob.java b/...in/java/org/apache/doris/nereids/worker/job/UnassignedGatherScanMultiRemoteTablesJob.java
@@ -42,6 +42,7 @@ public UnassignedGatherScanMultiRemoteTablesJob(PlanFragment fragment,
         super(fragment, scanNodes, exchangeToChildJob);
     }
 
+    /** canApply */
     public static boolean canApply(List<ScanNode> scanNodes) {
         if (scanNodes.size() <= 1) {
             return false;

diff --git a/...e/src/main/java/org/apache/doris/nereids/worker/job/UnassignedScanBucketOlapTableJob.java b/...e/src/main/java/org/apache/doris/nereids/worker/job/UnassignedScanBucketOlapTableJob.java
@@ -173,6 +173,7 @@ private boolean shouldFillUpInstances(List<HashJoinNode> hashJoinNodes) {
                 case RIGHT_SEMI_JOIN:
                 case RIGHT_ANTI_JOIN:
                     return true;
+                default:
             }
         }
         return false;

diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java b/fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java
@@ -3064,8 +3064,8 @@ public static boolean canUseNereidsDistributePlanner() {
                 (LogicalPlanAdapter) connectContext.getStatementContext().getParsedStatement();
         LogicalPlan logicalPlan = planAdapter.getLogicalPlan();
         SessionVariable sessionVariable = connectContext.getSessionVariable();
-        if (logicalPlan instanceof UnboundResultSink &&
-                sessionVariable.enableNereidsDistributePlanner && sessionVariable.enablePipelineXEngine) {
+        if (logicalPlan instanceof UnboundResultSink
+                && sessionVariable.enableNereidsDistributePlanner && sessionVariable.enablePipelineXEngine) {
             return true;
         }
         return false;