[GitHub] [hudi] LinMingQiang commented on a diff in pull request #5997: [HUDI-4338] resolve the data skew when using flink datastream write hudi

2022-07-04 Thread GitBox
LinMingQiang commented on code in PR #5997: URL: https://github.com/apache/hudi/pull/5997#discussion_r913335074 ## hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/utils/Pipelines.java: ## @@ -330,17 +330,23 @@ public static DataStream hoodieStreamWrite(Confi

[GitHub] [hudi] LinMingQiang commented on a diff in pull request #5997: [HUDI-4338] resolve the data skew when using flink datastream write hudi

2022-07-01 Thread GitBox
LinMingQiang commented on code in PR #5997: URL: https://github.com/apache/hudi/pull/5997#discussion_r912315747 ## hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/utils/Pipelines.java: ## @@ -330,17 +330,23 @@ public static DataStream hoodieStreamWrite(Confi

[GitHub] [hudi] LinMingQiang commented on a diff in pull request #5997: [HUDI-4338] resolve the data skew when using flink datastream write hudi

2022-07-01 Thread GitBox
LinMingQiang commented on code in PR #5997: URL: https://github.com/apache/hudi/pull/5997#discussion_r912314810 ## hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/utils/Pipelines.java: ## @@ -330,17 +330,23 @@ public static DataStream hoodieStreamWrite(Confi

[GitHub] [hudi] LinMingQiang commented on a diff in pull request #5997: [HUDI-4338] resolve the data skew when using flink datastream write hudi

2022-06-30 Thread GitBox
LinMingQiang commented on code in PR #5997: URL: https://github.com/apache/hudi/pull/5997#discussion_r911590451 ## hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/utils/Pipelines.java: ## @@ -330,17 +330,23 @@ public static DataStream hoodieStreamWrite(Confi

[GitHub] [hudi] LinMingQiang commented on a diff in pull request #5997: [HUDI-4338] resolve the data skew when using flink datastream write hudi

2022-06-30 Thread GitBox
LinMingQiang commented on code in PR #5997: URL: https://github.com/apache/hudi/pull/5997#discussion_r911076916 ## hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/utils/Pipelines.java: ## @@ -330,17 +330,23 @@ public static DataStream hoodieStreamWrite(Confi