[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 <[email protected]> Authored: Fri Feb 17 20:01:25 2017 +0100 Committer: Stephan Ewen <[email protected]> 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());
