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 2019/10/11 12:38:49 UTC
[flink] branch master updated (2c2095b -> 0bd0ec1)
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 2c2095b [hotfix][e2e] Disable Avro Confluent schema registry e2e test until FLINK-13567 has been fixed
add 1c74725 [hotfix][runtime, test] Unify formatting in StreamConfigChainer
add db6fdea [hotfix][runtime, test] Refactor StreamConfigChainer to support StreamOperatorFactory and honour pass down the bufferTimeout
add 0bd0ec1 [FLINK-14300][runtime, test] Add test making sure that RecordWriter is properly closed in case of early StreamTask failure
No new revisions were added by this update.
Summary of changes:
.../io/network/api/writer/RecordWriter.java | 8 ++-
.../flink/streaming/api/graph/StreamConfig.java | 4 +-
.../runtime/tasks/StreamConfigChainer.java | 50 ++++++++++----
.../streaming/runtime/tasks/StreamTaskTest.java | 76 ++++++++++++++++++++++
.../runtime/tasks/StreamTaskTestHarness.java | 2 +-
5 files changed, 121 insertions(+), 19 deletions(-)