[GitHub] [hudi] danny0405 commented on a change in pull request #3304: [HUDI-2198] Clean and reset the bootstrap events for coordinator when…

2022-03-16 Thread GitBox
danny0405 commented on a change in pull request #3304: URL: https://github.com/apache/hudi/pull/3304#discussion_r828713714 ## File path: hudi-flink/src/main/java/org/apache/hudi/sink/partitioner/BucketAssignFunction.java ## @@ -194,9 +194,10 @@ private void

[GitHub] [hudi] danny0405 commented on a change in pull request #3304: [HUDI-2198] Clean and reset the bootstrap events for coordinator when…

2021-07-20 Thread GitBox
danny0405 commented on a change in pull request #3304: URL: https://github.com/apache/hudi/pull/3304#discussion_r672946328 ## File path: hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteFunction.java ## @@ -534,6 +544,12 @@ private void bufferRecord(HoodieRecord

[GitHub] [hudi] danny0405 commented on a change in pull request #3304: [HUDI-2198] Clean and reset the bootstrap events for coordinator when…

2021-07-20 Thread GitBox
danny0405 commented on a change in pull request #3304: URL: https://github.com/apache/hudi/pull/3304#discussion_r672946328 ## File path: hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteFunction.java ## @@ -534,6 +544,12 @@ private void bufferRecord(HoodieRecord

[GitHub] [hudi] danny0405 commented on a change in pull request #3304: [HUDI-2198] Clean and reset the bootstrap events for coordinator when…

2021-07-20 Thread GitBox
danny0405 commented on a change in pull request #3304: URL: https://github.com/apache/hudi/pull/3304#discussion_r672946328 ## File path: hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteFunction.java ## @@ -534,6 +544,12 @@ private void bufferRecord(HoodieRecord