You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by pn...@apache.org on 2020/08/25 07:56:21 UTC
[flink] branch master updated (c0f382f -> f666b81)
This is an automated email from the ASF dual-hosted git repository.
pnowojski pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from c0f382f [FLINK-17330[runtime] Merge cyclic dependent pipelined regions into one region
add d4970e2 [FLINK-19040][test] Properly close operator in SourceOperatorTest
add f666b81 [FLINK-19040][task] Close SourceReader in SourceOperator
No new revisions were added by this update.
Summary of changes:
.../streaming/api/operators/SourceOperator.java | 1 +
.../api/operators/SourceOperatorTest.java | 92 ++++++++++++++--------
2 files changed, 58 insertions(+), 35 deletions(-)