You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2017/02/06 17:53:05 UTC
flink git commit: [FLINK-5652] [asyncIO] Fix
AsyncWaitOperatorTest.testTimeoutCleanup
Repository: flink
Updated Branches:
refs/heads/release-1.2 44c446419 -> 50a0eae91
[FLINK-5652] [asyncIO] Fix AsyncWaitOperatorTest.testTimeoutCleanup
Release 1.2 does not have a TestingTaskManagerRuntimeInfo. Therefore, we have to instantiate
a TaskManagerRuntimeInfo on our own.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/50a0eae9
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/50a0eae9
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/50a0eae9
Branch: refs/heads/release-1.2
Commit: 50a0eae9192fd39a05cb5449ed3bc44847deb868
Parents: 44c4464
Author: Till Rohrmann <tr...@apache.org>
Authored: Mon Feb 6 18:50:40 2017 +0100
Committer: Till Rohrmann <tr...@apache.org>
Committed: Mon Feb 6 18:50:40 2017 +0100
----------------------------------------------------------------------
.../streaming/api/operators/async/AsyncWaitOperatorTest.java | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/50a0eae9/flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/async/AsyncWaitOperatorTest.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/async/AsyncWaitOperatorTest.java b/flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/async/AsyncWaitOperatorTest.java
index 15715da..8fd8d0d 100644
--- a/flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/async/AsyncWaitOperatorTest.java
+++ b/flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/async/AsyncWaitOperatorTest.java
@@ -827,7 +827,10 @@ public class AsyncWaitOperatorTest extends TestLogger {
Environment environment = mock(Environment.class);
when(environment.getMetricGroup()).thenReturn(new UnregisteredTaskMetricsGroup());
- when(environment.getTaskManagerInfo()).thenReturn(new TestingTaskManagerRuntimeInfo());
+ when(environment.getTaskManagerInfo()).thenReturn(new TaskManagerRuntimeInfo(
+ "localhost",
+ new Configuration(),
+ System.getProperty("java.io.tmpdir")));
when(environment.getUserClassLoader()).thenReturn(getClass().getClassLoader());
when(environment.getTaskInfo()).thenReturn(new TaskInfo(
"testTask",