flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From trohrm...@apache.org
Subject flink git commit: [FLINK-5652] [asyncIO] Fix AsyncWaitOperatorTest.testTimeoutCleanup
Date Mon, 06 Feb 2017 17:53:05 GMT
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 <trohrmann@apache.org>
Authored: Mon Feb 6 18:50:40 2017 +0100
Committer: Till Rohrmann <trohrmann@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",


Mime
View raw message