Jiayi-Liao commented on a change in pull request #12243:
URL: https://github.com/apache/flink/pull/12243#discussion_r428063945
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/InputProcessorUtil.java
##
@@ -79,11 +80,26 @@ public static Ch
Jiayi-Liao commented on a change in pull request #12243:
URL: https://github.com/apache/flink/pull/12243#discussion_r427381013
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/InputProcessorUtil.java
##
@@ -79,11 +80,26 @@ public static Ch