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 7fd6a2dae73b8b2..10cd29277256c60 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 @@ -340,7 +340,7 @@ private static void enableLocalShuffle(TPipelineFragmentParams currentFragmentPa } private static void disableLocalShuffle(TPipelineFragmentParams currentFragmentParam) { - // disable local shuffle, because the parallel_instances == fragments.instances.size, + // disable local shuffle, because the parallel_instances == fragments.instances.size. // if a fragment use local shuffle, all instanceJob would be LocalShuffleAssignedJob. // if not, all instanceJob would be StaticAssignedJob. // so we can cumulative parallel_instances as the fragments.instances.size.