[GitHub] [hudi] yuzhaojing commented on a change in pull request #3134: [HUDI-2052] Support load logFile in BootstrapFunction

2021-06-25 Thread GitBox
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

[GitHub] [hudi] yuzhaojing commented on a change in pull request #3134: [HUDI-2052] Support load logFile in BootstrapFunction

2021-06-25 Thread GitBox
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

[GitHub] [hudi] yuzhaojing commented on a change in pull request #3134: [HUDI-2052] Support load logFile in BootstrapFunction

2021-06-24 Thread GitBox
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

[GitHub] [hudi] yuzhaojing commented on a change in pull request #3134: [HUDI-2052] Support load logFile in BootstrapFunction

2021-06-24 Thread GitBox
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

[GitHub] [hudi] yuzhaojing commented on a change in pull request #3134: [HUDI-2052] Support load logFile in BootstrapFunction

2021-06-23 Thread GitBox
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

[GitHub] [hudi] yuzhaojing commented on a change in pull request #3134: [HUDI-2052] Support load logFile in BootstrapFunction

2021-06-23 Thread GitBox
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