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 2021/06/07 10:15:01 UTC

[flink] branch master updated (11301c2 -> e7696fc)

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 11301c2  [FLINK-22895][docs] Fix example typo in "Table Concepts & Common API" page
     add aca5d81  [hotfix][network] Removed unused method in LocalInputChannel
     add 4b1f6b7  [hotfix][task] Remove unused constructor in TestTaskStateManager
     add 6e9c9b0  [hotfix][task] Rename triggerCheckpoint to better reflect a difference compared to other similarly named methods
     add 7e393dd  [hotfix][test] Deduplicate test case between SourceStreamTask and SourceOperatorStreamTask
     add e7696fc  [FLINK-22833][metrics] Set checkpointStartDelay in checkpoint metrics for SourceTasks

No new revisions were added by this update.

Summary of changes:
 .../partition/consumer/LocalInputChannel.java      | 22 -----
 .../flink/runtime/state/TestTaskStateManager.java  |  4 -
 .../flink/streaming/runtime/tasks/StreamTask.java  | 21 +++--
 .../tasks/SourceOperatorStreamTaskTest.java        | 52 ++----------
 .../runtime/tasks/SourceStreamTaskTest.java        | 66 ++++-----------
 .../runtime/tasks/SourceStreamTaskTestBase.java    | 98 ++++++++++++++++++++++
 6 files changed, 133 insertions(+), 130 deletions(-)
 create mode 100644 flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/SourceStreamTaskTestBase.java