[GitHub] [hudi] danny0405 commented on a change in pull request #2430: [HUDI-1522] Remove the single parallelism operator from the Flink writer

danny0405 commented on a change in pull request #2430: URL: https://github.com/apache/hudi/pull/2430#discussion_r554904669 ## File path: hudi-flink/src/main/java/org/apache/hudi/HoodieFlinkStreamer.java ## @@ -160,6 +156,19 @@ public static void main(String[] args) throws

[GitHub] [hudi] danny0405 commented on a change in pull request #2430: [HUDI-1522] Remove the single parallelism operator from the Flink writer

danny0405 commented on a change in pull request #2430: URL: https://github.com/apache/hudi/pull/2430#discussion_r554842872 ## File path: hudi-common/src/main/avro/HoodieRollbackMetadata.avsc ## @@ -51,10 +51,10 @@ /* overlaps with 'commitsRollback' field. Adding this to