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