wangxianghu commented on a change in pull request #3024:
URL: https://github.com/apache/hudi/pull/3024#discussion_r645943833
##
File path:
hudi-flink/src/main/java/org/apache/hudi/streamer/HoodieFlinkStreamer.java
##
@@ -93,8 +95,15 @@ public static void main(String[] args)
wangxianghu commented on a change in pull request #3024:
URL: https://github.com/apache/hudi/pull/3024#discussion_r645943934
##
File path: hudi-flink/src/main/java/org/apache/hudi/table/HoodieTableSink.java
##
@@ -73,10 +76,20 @@ public SinkRuntimeProvider
wangxianghu commented on a change in pull request #3024:
URL: https://github.com/apache/hudi/pull/3024#discussion_r645943833
##
File path:
hudi-flink/src/main/java/org/apache/hudi/streamer/HoodieFlinkStreamer.java
##
@@ -93,8 +95,15 @@ public static void main(String[] args)