yuzhaojing commented on a change in pull request #3134:
URL: https://github.com/apache/hudi/pull/3134#discussion_r658658537
##
File path:
hudi-flink/src/main/java/org/apache/hudi/sink/bootstrap/BootstrapFunction.java
##
@@ -168,32 +175,69 @@ private HoodieFlinkTable
yuzhaojing commented on a change in pull request #3134:
URL: https://github.com/apache/hudi/pull/3134#discussion_r658609372
##
File path:
hudi-flink/src/main/java/org/apache/hudi/sink/bootstrap/BootstrapFunction.java
##
@@ -168,32 +175,69 @@ private HoodieFlinkTable
yuzhaojing commented on a change in pull request #3134:
URL: https://github.com/apache/hudi/pull/3134#discussion_r657678102
##
File path:
hudi-flink/src/test/java/org/apache/hudi/sink/TestWriteMergeOnRead.java
##
@@ -83,10 +92,76 @@ protected void checkWrittenData(File
yuzhaojing commented on a change in pull request #3134:
URL: https://github.com/apache/hudi/pull/3134#discussion_r657662677
##
File path:
hudi-flink/src/test/java/org/apache/hudi/sink/TestWriteMergeOnRead.java
##
@@ -83,10 +92,76 @@ protected void checkWrittenData(File
yuzhaojing commented on a change in pull request #3134:
URL: https://github.com/apache/hudi/pull/3134#discussion_r657638827
##
File path:
hudi-flink/src/main/java/org/apache/hudi/sink/bootstrap/BootstrapFunction.java
##
@@ -168,33 +178,74 @@ private HoodieFlinkTable
yuzhaojing commented on a change in pull request #3134:
URL: https://github.com/apache/hudi/pull/3134#discussion_r657583870
##
File path:
hudi-flink/src/main/java/org/apache/hudi/sink/bootstrap/BootstrapFunction.java
##
@@ -197,10 +219,70 @@ private void loadRecords(String