rkhachatryan commented on a change in pull request #15331:
URL: https://github.com/apache/flink/pull/15331#discussion_r600153326
##
File path:
flink-core/src/main/java/org/apache/flink/api/common/operators/CollectionExecutor.java
##
@@ -110,7 +111,7 @@ public
rkhachatryan commented on a change in pull request #15331:
URL: https://github.com/apache/flink/pull/15331#discussion_r599331707
##
File path:
flink-core/src/main/java/org/apache/flink/api/common/operators/CollectionExecutor.java
##
@@ -192,14 +193,16 @@ private void