You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by zh...@apache.org on 2019/08/23 21:25:43 UTC
[flink] branch master updated (aa9ac7e -> d3f6f8e)
This is an automated email from the ASF dual-hosted git repository.
zhijiang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from aa9ac7e [FLINK-13430][build] Configure sending travis build notifications to builds@flink.apache.org
add a7f1fee [FLINK-13764][task,metrics] Pass the counter of numRecordsIn into the constructor of StreamInputProcessor
add d3f6f8e [hotfix][task] Adjust the code format of OneInputStreamTask
No new revisions were added by this update.
Summary of changes:
.../runtime/io/StreamOneInputProcessor.java | 21 ++++-------------
.../io/StreamTwoInputSelectableProcessor.java | 16 ++++---------
.../runtime/tasks/OneInputStreamTask.java | 27 +++++++++++-----------
.../flink/streaming/runtime/tasks/StreamTask.java | 12 ++++++++++
.../tasks/TwoInputSelectableStreamTask.java | 3 ++-
5 files changed, 36 insertions(+), 43 deletions(-)