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 2018/10/22 18:27:56 UTC

[flink] branch master updated (7b040b9 -> 7311f01)

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 7b040b9  [FLINK-10527] Cleanup constant isNewMode in YarnTestBase
     add 7311f01  [FLINK-10607][network][test] Unify to remove duplicated NoOpResultPartitionConsumableNotifier

No new revisions were added by this update.

Summary of changes:
 .../flink/runtime/io/network/NetworkEnvironmentTest.java      |  4 ++--
 .../partition/NoOpResultPartitionConsumableNotifier.java}     |  7 ++++---
 .../io/network/partition/consumer/LocalInputChannelTest.java  |  4 ++--
 .../apache/flink/runtime/taskexecutor/TaskExecutorTest.java   |  4 ++--
 .../apache/flink/runtime/taskmanager/TaskAsyncCallTest.java   |  3 ++-
 .../java/org/apache/flink/runtime/taskmanager/TaskTest.java   |  7 ++++---
 .../apache/flink/runtime/util/JvmExitOnFatalErrorTest.java    | 11 +----------
 .../io/benchmark/StreamNetworkBenchmarkEnvironment.java       |  8 +-------
 .../runtime/tasks/InterruptSensitiveRestoreTest.java          |  4 ++--
 .../streaming/runtime/tasks/StreamTaskTerminationTest.java    |  4 ++--
 .../apache/flink/streaming/runtime/tasks/StreamTaskTest.java  |  3 ++-
 .../runtime/tasks/TaskCheckpointingBehaviourTest.java         |  4 ++--
 12 files changed, 26 insertions(+), 37 deletions(-)
 copy flink-runtime/src/{main/java/org/apache/flink/runtime/io/network/partition/ResultPartitionConsumableNotifier.java => test/java/org/apache/flink/runtime/io/network/partition/NoOpResultPartitionConsumableNotifier.java} (77%)