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 2020/02/11 10:04:16 UTC

[flink] branch master updated (57c3396 -> 2a0555b)

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 57c3396  [FLINK-15561] Unify Kerberos credentials checking
     add 2558c9e  [hotfix][task] Fix the comment typo in TwoInputStreamTask class
     add 2a0555b  [FLINK-15914][checkpointing][metrics] Miss the checkpoint related metrics for the case of two inputs

No new revisions were added by this update.

Summary of changes:
 .../apache/flink/runtime/metrics/MetricNames.java  |  3 ++
 .../flink/runtime/metrics/NoOpMetricRegistry.java  |  2 +-
 .../metrics/groups/UnregisteredMetricGroups.java   |  2 +-
 .../runtime/io/CheckpointedInputGate.java          |  7 ++--
 .../streaming/runtime/io/InputProcessorUtil.java   | 13 +++++++
 .../runtime/tasks/OneInputStreamTask.java          |  6 +---
 .../runtime/tasks/TwoInputStreamTask.java          |  3 +-
 .../runtime/tasks/OneInputStreamTaskTest.java      | 34 ++++++++++++++++++
 .../runtime/tasks/StreamMockEnvironment.java       |  8 ++++-
 .../runtime/tasks/StreamTaskTestHarness.java       | 41 ++++++++++++++++++++++
 .../runtime/tasks/TwoInputStreamTaskTest.java      | 38 ++++++++++++++++++++
 11 files changed, 146 insertions(+), 11 deletions(-)