Skip to content

Commit

Permalink
success local shuffle + bucket shuffle join
Browse files Browse the repository at this point in the history
  • Loading branch information
924060929 committed Sep 30, 2024
1 parent 5940c74 commit ac972b0
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -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.
Expand Down

0 comments on commit ac972b0

Please sign in to comment.