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 11:07:02 UTC
[6/9] 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/048a21c0
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/048a21c0
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/048a21c0
Branch: refs/heads/release-1.2
Commit: 048a21c097060c78e4ef2552c8c774ff56065099
Parents: 7cdbd3c
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 02:07:55 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/048a21c0/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 398505f..b8d1d8b 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
@@ -171,9 +171,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));
executor = new ForkJoinPool();
@@ -194,7 +192,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(
@@ -368,7 +366,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());