[GitHub] [hudi] LinMingQiang commented on a diff in pull request #8338: [HUDI-5996] Verify the consistency of bucket num at job sta…

2023-04-03 Thread via GitHub
LinMingQiang commented on code in PR #8338: URL: https://github.com/apache/hudi/pull/8338#discussion_r1155829734 ## hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/StreamerUtil.java: ## @@ -217,18 +218,52 @@ public static HoodieTableMetaClient

[GitHub] [hudi] LinMingQiang commented on a diff in pull request #8338: [HUDI-5996] Verify the consistency of bucket num at job sta…

2023-04-03 Thread via GitHub
LinMingQiang commented on code in PR #8338: URL: https://github.com/apache/hudi/pull/8338#discussion_r1155668406 ## hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/StreamerUtil.java: ## @@ -217,18 +218,52 @@ public static HoodieTableMetaClient

[GitHub] [hudi] LinMingQiang commented on a diff in pull request #8338: [HUDI-5996] Verify the consistency of bucket num at job sta…

2023-04-03 Thread via GitHub
LinMingQiang commented on code in PR #8338: URL: https://github.com/apache/hudi/pull/8338#discussion_r1155668406 ## hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/StreamerUtil.java: ## @@ -217,18 +218,52 @@ public static HoodieTableMetaClient

[GitHub] [hudi] LinMingQiang commented on a diff in pull request #8338: [HUDI-5996] Verify the consistency of bucket num at job sta…

2023-04-03 Thread via GitHub
LinMingQiang commented on code in PR #8338: URL: https://github.com/apache/hudi/pull/8338#discussion_r1155515424 ## hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/StreamerUtil.java: ## @@ -217,18 +218,52 @@ public static HoodieTableMetaClient

[GitHub] [hudi] LinMingQiang commented on a diff in pull request #8338: [HUDI-5996] Verify the consistency of bucket num at job sta…

2023-04-01 Thread via GitHub
LinMingQiang commented on code in PR #8338: URL: https://github.com/apache/hudi/pull/8338#discussion_r1155123399 ## hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/StreamerUtil.java: ## @@ -217,18 +218,52 @@ public static HoodieTableMetaClient