zhijiangW commented on a change in pull request #9879: [FLINK-14300][runtime,
test] Add test making sure that RecordWriter is properly closed in case of
early StreamTask failure
URL: https://github.com/apache/flink/pull/9879#discussion_r333846291
##
File path:
flink-streaming-java
zhijiangW commented on a change in pull request #9879: [FLINK-14300][runtime,
test] Add test making sure that RecordWriter is properly closed in case of
early StreamTask failure
URL: https://github.com/apache/flink/pull/9879#discussion_r333843383
##
File path:
flink-streaming-java
zhijiangW commented on a change in pull request #9879: [FLINK-14300][runtime,
test] Add test making sure that RecordWriter is properly closed in case of
early StreamTask failure
URL: https://github.com/apache/flink/pull/9879#discussion_r333842749
##
File path:
flink-runtime/src/ma