[GitHub] [hudi] yanghua commented on a change in pull request #2785: [HUDI-1775] Add option for compaction parallelism

yanghua commented on a change in pull request #2785: URL: https://github.com/apache/hudi/pull/2785#discussion_r610278459 ## File path: hudi-flink/src/main/java/org/apache/hudi/sink/partitioner/BucketAssignFunction.java ## @@ -159,8 +164,11 @@ public void processElement(I

[GitHub] [hudi] yanghua commented on a change in pull request #2785: [HUDI-1775] Add option for compaction parallelism

yanghua commented on a change in pull request #2785: URL: https://github.com/apache/hudi/pull/2785#discussion_r609610921 ## File path: hudi-flink/src/main/java/org/apache/hudi/sink/partitioner/BucketAssignFunction.java ## @@ -159,8 +164,11 @@ public void processElement(I