[GitHub] [hudi] wangxianghu commented on a change in pull request #3024: [HUDI-1924] Add BootstrapFunction to support index bootstrap

2021-06-04 Thread GitBox
wangxianghu commented on a change in pull request #3024: URL: https://github.com/apache/hudi/pull/3024#discussion_r645943833 ## File path: hudi-flink/src/main/java/org/apache/hudi/streamer/HoodieFlinkStreamer.java ## @@ -93,8 +95,15 @@ public static void main(String[] args)

[GitHub] [hudi] wangxianghu commented on a change in pull request #3024: [HUDI-1924] Add BootstrapFunction to support index bootstrap

2021-06-04 Thread GitBox
wangxianghu commented on a change in pull request #3024: URL: https://github.com/apache/hudi/pull/3024#discussion_r645943934 ## File path: hudi-flink/src/main/java/org/apache/hudi/table/HoodieTableSink.java ## @@ -73,10 +76,20 @@ public SinkRuntimeProvider

[GitHub] [hudi] wangxianghu commented on a change in pull request #3024: [HUDI-1924] Add BootstrapFunction to support index bootstrap

2021-06-04 Thread GitBox
wangxianghu commented on a change in pull request #3024: URL: https://github.com/apache/hudi/pull/3024#discussion_r645943833 ## File path: hudi-flink/src/main/java/org/apache/hudi/streamer/HoodieFlinkStreamer.java ## @@ -93,8 +95,15 @@ public static void main(String[] args)