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 2020/07/29 08:04:03 UTC

[flink] branch master updated (c137102 -> 35fed94)

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 c137102  [FLINK-18595][network] Fix the deadlock of concurrently recycling buffer and releasing input channel
     add 457173c  [FLINK-18656][task] Provide checkpointStartDelayNanos for SourceStreamTask
     add 35fed94  [FLINK-18656][tests] Rename MultipleInputStreamTaskTestHarnessBuilder to StreamTaskMailboxTestHarnessBuilder

No new revisions were added by this update.

Summary of changes:
 .../streaming/runtime/tasks/SourceStreamTask.java  |   2 +
 .../flink/streaming/runtime/tasks/StreamTask.java  |   9 ++
 .../runtime/tasks/MultipleInputStreamTaskTest.java |  22 ++---
 .../MultipleInputStreamTaskTestHarnessBuilder.java | 108 ---------------------
 .../tasks/SourceOperatorStreamTaskTest.java        |   4 +-
 .../runtime/tasks/SourceStreamTaskTest.java        |  40 ++++++++
 .../tasks/StreamTaskMailboxTestHarnessBuilder.java |  61 +++++++++++-
 ...treamTaskMultipleInputSelectiveReadingTest.java |   4 +-
 .../streaming/runtime/tasks/StreamTaskTest.java    |  12 +--
 9 files changed, 131 insertions(+), 131 deletions(-)
 delete mode 100644 flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/MultipleInputStreamTaskTestHarnessBuilder.java