You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2017/02/20 00:55:32 UTC
[18/19] flink git commit: [hotfix] [tests] Use random actor names in
JobManagerHARecoveryTest to avoid name collisions
[hotfix] [tests] Use random actor names in JobManagerHARecoveryTest to avoid name collisions
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/31c26e3f
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/31c26e3f
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/31c26e3f
Branch: refs/heads/master
Commit: 31c26e3fc06ad1939284249547c3885a5b62a8f3
Parents: 082d40f
Author: Stephan Ewen <se...@apache.org>
Authored: Fri Feb 17 20:01:25 2017 +0100
Committer: Stephan Ewen <se...@apache.org>
Committed: Mon Feb 20 01:01:24 2017 +0100
----------------------------------------------------------------------
.../flink/runtime/jobmanager/JobManagerHARecoveryTest.java | 8 +++-----
1 file changed, 3 insertions(+), 5 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/31c26e3f/flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/JobManagerHARecoveryTest.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/JobManagerHARecoveryTest.java b/flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/JobManagerHARecoveryTest.java
index 8985a34..5f2edac 100644
--- a/flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/JobManagerHARecoveryTest.java
+++ b/flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/JobManagerHARecoveryTest.java
@@ -169,9 +169,7 @@ public class JobManagerHARecoveryTest {
InstanceManager instanceManager = new InstanceManager();
instanceManager.addInstanceListener(scheduler);
- archive = system.actorOf(Props.create(
- MemoryArchivist.class,
- 10), "archive");
+ archive = system.actorOf(Props.create(MemoryArchivist.class, 10));
Props jobManagerProps = Props.create(
TestingJobManager.class,
@@ -190,7 +188,7 @@ public class JobManagerHARecoveryTest {
jobRecoveryTimeout,
Option.apply(null));
- jobManager = system.actorOf(jobManagerProps, "jobmanager");
+ jobManager = system.actorOf(jobManagerProps);
ActorGateway gateway = new AkkaActorGateway(jobManager, leaderSessionID);
taskManager = TaskManager.startTaskManagerComponentsAndActor(
@@ -360,7 +358,7 @@ public class JobManagerHARecoveryTest {
Option.<MetricRegistry>apply(null),
recoveredJobs).withDispatcher(CallingThreadDispatcher.Id());
- jobManager = system.actorOf(jobManagerProps, "jobmanager");
+ jobManager = system.actorOf(jobManagerProps);
Future<Object> started = Patterns.ask(jobManager, new Identify(42), deadline.timeLeft().toMillis());