[jira] [Commented] (FLINK-1831) runtime.taskmanager.RegistrationTests fails spuriously

2015-09-18 Thread Till Rohrmann (JIRA) 

[ 
https://issues.apache.org/jira/browse/FLINK-1831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14847317#comment-14847317
 ] 

Till Rohrmann commented on FLINK-1831:
--

The posted log is not really helpful in tracking down the problem. Maybe the 
timeout for the task manager registration is too low. We can increase it to see 
whether the problem occurs again.

> runtime.taskmanager.RegistrationTests fails spuriously
> --
>
> Key: FLINK-1831
> URL: https://issues.apache.org/jira/browse/FLINK-1831
> Project: Flink
>  Issue Type: Bug
>  Components: Distributed Runtime
>Affects Versions: 0.9
>Reporter: Márton Balassi
>Assignee: Stephan Ewen
> Fix For: 0.9
>
>
> Failing in a decent chunk of travis builds, I could also reproduce it locally:
> akka.actor.InvalidActorNameException: actor name [FAKE_JOB_MANAGER] is not 
> unique!
>   at 
> akka.actor.dungeon.ChildrenContainer$TerminatingChildrenContainer.reserve(ChildrenContainer.scala:192)
>   at akka.actor.dungeon.Children$class.reserveChild(Children.scala:77)
>   at akka.actor.ActorCell.reserveChild(ActorCell.scala:369)
>   at akka.actor.dungeon.Children$class.makeChild(Children.scala:202)
>   at akka.actor.dungeon.Children$class.attachChild(Children.scala:42)
>   at akka.actor.ActorCell.attachChild(ActorCell.scala:369)
>   at akka.actor.ActorSystemImpl.actorOf(ActorSystem.scala:553)
>   at 
> org.apache.flink.runtime.taskmanager.RegistrationTest$5.(RegistrationTest.java:308)
>   at 
> org.apache.flink.runtime.taskmanager.RegistrationTest.testTaskManagerResumesConnectAfterJobManagerFailure(RegistrationTest.java:266)
>   at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
>   at 
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
>   at 
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
>   at java.lang.reflect.Method.invoke(Method.java:497)
>   at 
> org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:47)
>   at 
> org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
>   at 
> org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:44)
>   at 
> org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
>   at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:271)
>   at 
> org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:70)
>   at 
> org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:50)
>   at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
>   at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
>   at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
>   at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
>   at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
>   at 
> org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
>   at 
> org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
>   at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
>   at org.junit.runner.JUnitCore.run(JUnitCore.java:160)
>   at 
> com.intellij.junit4.JUnit4IdeaTestRunner.startRunnerWithArgs(JUnit4IdeaTestRunner.java:74)
>   at 
> com.intellij.rt.execution.junit.JUnitStarter.prepareStreamsAndStart(JUnitStarter.java:211)
>   at 
> com.intellij.rt.execution.junit.JUnitStarter.main(JUnitStarter.java:67)
>   at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
>   at 
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
>   at 
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
>   at java.lang.reflect.Method.invoke(Method.java:497)
>   at com.intellij.rt.execution.application.AppMain.main(AppMain.java:134)
> 09:46:39.486 [flink-akka.actor.default-dispatcher-2] 
> [flink-akka.actor.default-dispatcher-3 - akka://flink/user/FAKE_JOB_MANAGER] 
> ERROR akka.actor.OneForOneStrategy - Kill
> akka.actor.ActorKilledException: Kill
> java.lang.AssertionError: actor name [FAKE_JOB_MANAGER] is not unique!
>   at org.junit.Assert.fail(Assert.java:88)
>   at 
> org.apache.flink.runtime.taskmanager.RegistrationTest$5.(RegistrationTest.java:328)
>   at 
> org.apache.flink.runtime.taskmanager.RegistrationTest.testTaskManagerResumesConnectAfterJobManagerFailure(RegistrationTest.java:266)
>   at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
>   at 
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
>   at 
>

[jira] [Commented] (FLINK-1831) runtime.taskmanager.RegistrationTests fails spuriously

2015-09-16 Thread Robert Metzger (JIRA) 

[ 
https://issues.apache.org/jira/browse/FLINK-1831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14768887#comment-14768887
 ] 

Robert Metzger commented on FLINK-1831:
---

I'm not re-opening this issue, but I saw this test failing again 

{code}
Failed tests: 
  
TaskManagerRegistrationTest.testTaskManagerResumesConnectAfterJobManagerFailure:330
 assertion failed: block took 2.001 seconds, exceeding 2.000 seconds
{code}
If this is happening again, we might need to look into it again: 
https://travis-ci.org/apache/flink/jobs/80454923

> runtime.taskmanager.RegistrationTests fails spuriously
> --
>
> Key: FLINK-1831
> URL: https://issues.apache.org/jira/browse/FLINK-1831
> Project: Flink
>  Issue Type: Bug
>  Components: Distributed Runtime
>Affects Versions: 0.9
>Reporter: Márton Balassi
>Assignee: Stephan Ewen
> Fix For: 0.9
>
>
> Failing in a decent chunk of travis builds, I could also reproduce it locally:
> akka.actor.InvalidActorNameException: actor name [FAKE_JOB_MANAGER] is not 
> unique!
>   at 
> akka.actor.dungeon.ChildrenContainer$TerminatingChildrenContainer.reserve(ChildrenContainer.scala:192)
>   at akka.actor.dungeon.Children$class.reserveChild(Children.scala:77)
>   at akka.actor.ActorCell.reserveChild(ActorCell.scala:369)
>   at akka.actor.dungeon.Children$class.makeChild(Children.scala:202)
>   at akka.actor.dungeon.Children$class.attachChild(Children.scala:42)
>   at akka.actor.ActorCell.attachChild(ActorCell.scala:369)
>   at akka.actor.ActorSystemImpl.actorOf(ActorSystem.scala:553)
>   at 
> org.apache.flink.runtime.taskmanager.RegistrationTest$5.(RegistrationTest.java:308)
>   at 
> org.apache.flink.runtime.taskmanager.RegistrationTest.testTaskManagerResumesConnectAfterJobManagerFailure(RegistrationTest.java:266)
>   at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
>   at 
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
>   at 
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
>   at java.lang.reflect.Method.invoke(Method.java:497)
>   at 
> org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:47)
>   at 
> org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
>   at 
> org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:44)
>   at 
> org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
>   at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:271)
>   at 
> org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:70)
>   at 
> org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:50)
>   at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
>   at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
>   at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
>   at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
>   at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
>   at 
> org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
>   at 
> org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
>   at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
>   at org.junit.runner.JUnitCore.run(JUnitCore.java:160)
>   at 
> com.intellij.junit4.JUnit4IdeaTestRunner.startRunnerWithArgs(JUnit4IdeaTestRunner.java:74)
>   at 
> com.intellij.rt.execution.junit.JUnitStarter.prepareStreamsAndStart(JUnitStarter.java:211)
>   at 
> com.intellij.rt.execution.junit.JUnitStarter.main(JUnitStarter.java:67)
>   at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
>   at 
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
>   at 
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
>   at java.lang.reflect.Method.invoke(Method.java:497)
>   at com.intellij.rt.execution.application.AppMain.main(AppMain.java:134)
> 09:46:39.486 [flink-akka.actor.default-dispatcher-2] 
> [flink-akka.actor.default-dispatcher-3 - akka://flink/user/FAKE_JOB_MANAGER] 
> ERROR akka.actor.OneForOneStrategy - Kill
> akka.actor.ActorKilledException: Kill
> java.lang.AssertionError: actor name [FAKE_JOB_MANAGER] is not unique!
>   at org.junit.Assert.fail(Assert.java:88)
>   at 
> org.apache.flink.runtime.taskmanager.RegistrationTest$5.(RegistrationTest.java:328)
>   at 
> org.apache.flink.runtime.taskmanager.RegistrationTest.testTaskManagerResumesConnectAfterJobManagerFailure(RegistrationTest.java:266)
>   at