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
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
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
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
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