[GitHub] [hudi] wangxianghu commented on a change in pull request #3270: [HUDI-2165] Support Transformer for HoodieFlinkStreamer

2021-07-14 Thread GitBox
wangxianghu commented on a change in pull request #3270: URL: https://github.com/apache/hudi/pull/3270#discussion_r669354873 ## File path: hudi-flink/src/test/java/org/apache/hudi/sink/StreamWriteITCase.java ## @@ -91,78 +95,66 @@ protected static final Logger LOG = LoggerF

[GitHub] [hudi] wangxianghu commented on a change in pull request #3270: [HUDI-2165] Support Transformer for HoodieFlinkStreamer

2021-07-14 Thread GitBox
wangxianghu commented on a change in pull request #3270: URL: https://github.com/apache/hudi/pull/3270#discussion_r669321633 ## File path: hudi-flink/src/main/java/org/apache/hudi/streamer/FlinkStreamerConfig.java ## @@ -117,6 +117,9 @@ @Parameter(names = {"--commit-on-erro