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 [email protected]
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(-)
