[jira] [Created] (FLINK-1540) JobManagerFailsITCase Startup timed out on travis

[Shang Yuanchun (Jira)]

Robert Metzger created FLINK-1540:
-------------------------------------

             Summary: JobManagerFailsITCase Startup timed out on travis
                 Key: FLINK-1540
                 URL: https://issues.apache.org/jira/browse/FLINK-1540
             Project: Flink
          Issue Type: Bug
          Components: JobManager
    Affects Versions: 0.9
            Reporter: Robert Metzger


{code}
[ERROR] [02/13/2015 15:47:47.429] [main-ScalaTest-running-JobManagerFailsITCase] [Remoting] Remoting error: [Startup timed out] [
akka.remote.RemoteTransportException: Startup timed out
        at akka.remote.Remoting.akka$remote$Remoting$$notifyError(Remoting.scala:129)
        at akka.remote.Remoting.start(Remoting.scala:191)
        at akka.remote.RemoteActorRefProvider.init(RemoteActorRefProvider.scala:184)
        at akka.actor.ActorSystemImpl._start$lzycompute(ActorSystem.scala:579)
        at akka.actor.ActorSystemImpl._start(ActorSystem.scala:577)
        at akka.actor.ActorSystemImpl.start(ActorSystem.scala:588)
        at akka.actor.ActorSystem$.apply(ActorSystem.scala:111)
        at akka.actor.ActorSystem$.apply(ActorSystem.scala:104)
        at akka.actor.ActorSystem$.create(ActorSystem.scala:66)
        at org.apache.flink.runtime.akka.AkkaUtils$.createActorSystem(AkkaUtils.scala:68)
        at org.apache.flink.runtime.minicluster.FlinkMiniCluster.startJobManagerActorSystem(FlinkMiniCluster.scala:91)
        at org.apache.flink.runtime.minicluster.FlinkMiniCluster.<init>(FlinkMiniCluster.scala:51)
        at org.apache.flink.runtime.testingUtils.TestingCluster.<init>(TestingCluster.scala:36)
        at org.apache.flink.runtime.testingUtils.TestingUtils$.startTestingClusterDeathWatch(TestingUtils.scala:106)
        at org.apache.flink.runtime.jobmanager.JobManagerFailsITCase$$anonfun$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(JobManagerFailsITCase.scala:45)
        at org.apache.flink.runtime.jobmanager.JobManagerFailsITCase$$anonfun$1$$anonfun$apply$mcV$sp$1.apply(JobManagerFailsITCase.scala:42)
        at org.apache.flink.runtime.jobmanager.JobManagerFailsITCase$$anonfun$1$$anonfun$apply$mcV$sp$1.apply(JobManagerFailsITCase.scala:42)
        at org.scalatest.Transformer$$anonfun$apply$1.apply$mcV$sp(Transformer.scala:22)
        at org.scalatest.OutcomeOf$class.outcomeOf(OutcomeOf.scala:85)
        at org.scalatest.OutcomeOf$.outcomeOf(OutcomeOf.scala:104)
        at org.scalatest.Transformer.apply(Transformer.scala:22)
        at org.scalatest.Transformer.apply(Transformer.scala:20)
        at org.scalatest.WordSpecLike$$anon$1.apply(WordSpecLike.scala:953)
        at org.scalatest.Suite$class.withFixture(Suite.scala:1122)
        at org.apache.flink.runtime.jobmanager.JobManagerFailsITCase.withFixture(JobManagerFailsITCase.scala:32)
        at org.scalatest.WordSpecLike$class.invokeWithFixture$1(WordSpecLike.scala:950)
        at org.scalatest.WordSpecLike$$anonfun$runTest$1.apply(WordSpecLike.scala:962)
        at org.scalatest.WordSpecLike$$anonfun$runTest$1.apply(WordSpecLike.scala:962)
        at org.scalatest.SuperEngine.runTestImpl(Engine.scala:306)
        at org.scalatest.WordSpecLike$class.runTest(WordSpecLike.scala:962)
        at org.apache.flink.runtime.jobmanager.JobManagerFailsITCase.runTest(JobManagerFailsITCase.scala:32)
        at org.scalatest.WordSpecLike$$anonfun$runTests$1.apply(WordSpecLike.scala:1021)
        at org.scalatest.WordSpecLike$$anonfun$runTests$1.apply(WordSpecLike.scala:1021)
        at org.scalatest.SuperEngine$$anonfun$traverseSubNodes$1$1.apply(Engine.scala:413)
        at org.scalatest.SuperEngine$$anonfun$traverseSubNodes$1$1.apply(Engine.scala:401)
        at scala.collection.immutable.List.foreach(List.scala:318)
        at org.scalatest.SuperEngine.traverseSubNodes$1(Engine.scala:401)
        at org.scalatest.SuperEngine.org$scalatest$SuperEngine$$runTestsInBranch(Engine.scala:390)
        at org.scalatest.SuperEngine$$anonfun$traverseSubNodes$1$1.apply(Engine.scala:427)
        at org.scalatest.SuperEngine$$anonfun$traverseSubNodes$1$1.apply(Engine.scala:401)
        at scala.collection.immutable.List.foreach(List.scala:318)
        at org.scalatest.SuperEngine.traverseSubNodes$1(Engine.scala:401)
        at org.scalatest.SuperEngine.org$scalatest$SuperEngine$$runTestsInBranch(Engine.scala:396)
        at org.scalatest.SuperEngine.runTestsImpl(Engine.scala:483)
        at org.scalatest.WordSpecLike$class.runTests(WordSpecLike.scala:1021)
        at org.apache.flink.runtime.jobmanager.JobManagerFailsITCase.runTests(JobManagerFailsITCase.scala:32)
        at org.scalatest.Suite$class.run(Suite.scala:1424)
        at org.apache.flink.runtime.jobmanager.JobManagerFailsITCase.org$scalatest$WordSpecLike$$super$run(JobManagerFailsITCase.scala:32)
        at org.scalatest.WordSpecLike$$anonfun$run$1.apply(WordSpecLike.scala:1067)
        at org.scalatest.WordSpecLike$$anonfun$run$1.apply(WordSpecLike.scala:1067)
        at org.scalatest.SuperEngine.runImpl(Engine.scala:545)
        at org.scalatest.WordSpecLike$class.run(WordSpecLike.scala:1067)
        at org.apache.flink.runtime.jobmanager.JobManagerFailsITCase.org$scalatest$BeforeAndAfterAll$$super$run(JobManagerFailsITCase.scala:32)
        at org.scalatest.BeforeAndAfterAll$class.liftedTree1$1(BeforeAndAfterAll.scala:257)
        at org.scalatest.BeforeAndAfterAll$class.run(BeforeAndAfterAll.scala:256)
        at org.apache.flink.runtime.jobmanager.JobManagerFailsITCase.run(JobManagerFailsITCase.scala:32)
        at org.scalatest.junit.JUnitRunner.run(JUnitRunner.scala:99)
        at org.apache.maven.surefire.junit4.JUnit4Provider.execute(JUnit4Provider.java:264)
        at org.apache.maven.surefire.junit4.JUnit4Provider.executeTestSet(JUnit4Provider.java:153)
        at org.apache.maven.surefire.junit4.JUnit4Provider.invoke(JUnit4Provider.java:124)
        at org.apache.maven.surefire.booter.ForkedBooter.invokeProviderInSameClassLoader(ForkedBooter.java:200)
        at org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:153)
        at org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:103)
Caused by: java.util.concurrent.TimeoutException: Futures timed out after [200000 milliseconds]
        at scala.concurrent.impl.Promise$DefaultPromise.ready(Promise.scala:219)
        at scala.concurrent.impl.Promise$DefaultPromise.result(Promise.scala:223)
        at scala.concurrent.Await$$anonfun$result$1.apply(package.scala:107)
        at scala.concurrent.BlockContext$DefaultBlockContext$.blockOn(BlockContext.scala:53)
        at scala.concurrent.Await$.result(package.scala:107)
        at akka.remote.Remoting.start(Remoting.scala:173)
        ... 61 more
]
Tests run: 1, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 202.111 sec <<< FAILURE! - in org.apache.flink.runtime.jobmanager.JobManagerFailsITCase
The TaskManager should detect a lost connection to the JobManager and try to reconnect to it(org.apache.flink.runtime.jobmanager.JobManagerFailsITCase)  Time elapsed: 200.291 sec  <<< ERROR!
java.util.concurrent.TimeoutException: Futures timed out after [200000 milliseconds]
        at scala.concurrent.impl.Promise$DefaultPromise.ready(Promise.scala:219)
        at scala.concurrent.impl.Promise$DefaultPromise.result(Promise.scala:223)
        at scala.concurrent.Await$$anonfun$result$1.apply(package.scala:107)
        at scala.concurrent.BlockContext$DefaultBlockContext$.blockOn(BlockContext.scala:53)
        at scala.concurrent.Await$.result(package.scala:107)
        at akka.remote.Remoting.start(Remoting.scala:173)
        at akka.remote.RemoteActorRefProvider.init(RemoteActorRefProvider.scala:184)
        at akka.actor.ActorSystemImpl._start$lzycompute(ActorSystem.scala:579)
        at akka.actor.ActorSystemImpl._start(ActorSystem.scala:577)
        at akka.actor.ActorSystemImpl.start(ActorSystem.scala:588)
        at akka.actor.ActorSystem$.apply(ActorSystem.scala:111)
        at akka.actor.ActorSystem$.apply(ActorSystem.scala:104)
        at akka.actor.ActorSystem$.create(ActorSystem.scala:66)
        at org.apache.flink.runtime.akka.AkkaUtils$.createActorSystem(AkkaUtils.scala:68)
        at org.apache.flink.runtime.minicluster.FlinkMiniCluster.startJobManagerActorSystem(FlinkMiniCluster.scala:91)
        at org.apache.flink.runtime.minicluster.FlinkMiniCluster.<init>(FlinkMiniCluster.scala:51)
        at org.apache.flink.runtime.testingUtils.TestingCluster.<init>(TestingCluster.scala:36)
        at org.apache.flink.runtime.testingUtils.TestingUtils$.startTestingClusterDeathWatch(TestingUtils.scala:106)
        at org.apache.flink.runtime.jobmanager.JobManagerFailsITCase$$anonfun$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(JobManagerFailsITCase.scala:45)
        at org.apache.flink.runtime.jobmanager.JobManagerFailsITCase$$anonfun$1$$anonfun$apply$mcV$sp$1.apply(JobManagerFailsITCase.scala:42)
        at org.apache.flink.runtime.jobmanager.JobManagerFailsITCase$$anonfun$1$$anonfun$apply$mcV$sp$1.apply(JobManagerFailsITCase.scala:42)
        at org.scalatest.Transformer$$anonfun$apply$1.apply$mcV$sp(Transformer.scala:22)
        at org.scalatest.OutcomeOf$class.outcomeOf(OutcomeOf.scala:85)
        at org.scalatest.OutcomeOf$.outcomeOf(OutcomeOf.scala:104)
        at org.scalatest.Transformer.apply(Transformer.scala:22)
        at org.scalatest.Transformer.apply(Transformer.scala:20)
        at org.scalatest.WordSpecLike$$anon$1.apply(WordSpecLike.scala:953)
        at org.scalatest.Suite$class.withFixture(Suite.scala:1122)
        at org.apache.flink.runtime.jobmanager.JobManagerFailsITCase.withFixture(JobManagerFailsITCase.scala:32)

Running org.apache.flink.runtime.jobmanager.TaskManagerFailsWithSlotSharingITCase
Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 1.898 sec - in org.apache.flink.runtime.jobmanager.TaskManagerFailsWithSlotSharingITCase
Running org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase
Tests run: 6, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 18.791 sec - in org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase
Running org.apache.flink.runtime.operators.hash.HashTableITCase
[ERROR] [02/13/2015 15:48:10.604] [main-ScalaTest-running-TaskManagerFailsITCase] [Remoting] Remoting error: [Startup timed out] [
akka.remote.RemoteTransportException: Startup timed out
        at akka.remote.Remoting.akka$remote$Remoting$$notifyError(Remoting.scala:129)
        at akka.remote.Remoting.start(Remoting.scala:191)
        at akka.remote.RemoteActorRefProvider.init(RemoteActorRefProvider.scala:184)
        at akka.actor.ActorSystemImpl._start$lzycompute(ActorSystem.scala:579)
        at akka.actor.ActorSystemImpl._start(ActorSystem.scala:577)
        at akka.actor.ActorSystemImpl.start(ActorSystem.scala:588)
        at akka.actor.ActorSystem$.apply(ActorSystem.scala:111)
        at akka.actor.ActorSystem$.apply(ActorSystem.scala:104)
        at akka.actor.ActorSystem$.create(ActorSystem.scala:66)
        at org.apache.flink.runtime.akka.AkkaUtils$.createActorSystem(AkkaUtils.scala:68)
        at org.apache.flink.runtime.minicluster.FlinkMiniCluster.startJobManagerActorSystem(FlinkMiniCluster.scala:91)
        at org.apache.flink.runtime.minicluster.FlinkMiniCluster.<init>(FlinkMiniCluster.scala:51)
        at org.apache.flink.runtime.testingUtils.TestingCluster.<init>(TestingCluster.scala:36)
        at org.apache.flink.runtime.testingUtils.TestingUtils$.startTestingClusterDeathWatch(TestingUtils.scala:106)
        at org.apache.flink.runtime.jobmanager.TaskManagerFailsITCase$$anonfun$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(TaskManagerFailsITCase.scala:48)
        at org.apache.flink.runtime.jobmanager.TaskManagerFailsITCase$$anonfun$1$$anonfun$apply$mcV$sp$1.apply(TaskManagerFailsITCase.scala:45)
        at org.apache.flink.runtime.jobmanager.TaskManagerFailsITCase$$anonfun$1$$anonfun$apply$mcV$sp$1.apply(TaskManagerFailsITCase.scala:45)
        at org.scalatest.Transformer$$anonfun$apply$1.apply$mcV$sp(Transformer.scala:22)
        at org.scalatest.OutcomeOf$class.outcomeOf(OutcomeOf.scala:85)
        at org.scalatest.OutcomeOf$.outcomeOf(OutcomeOf.scala:104)
        at org.scalatest.Transformer.apply(Transformer.scala:22)
        at org.scalatest.Transformer.apply(Transformer.scala:20)
        at org.scalatest.WordSpecLike$$anon$1.apply(WordSpecLike.scala:953)
        at org.scalatest.Suite$class.withFixture(Suite.scala:1122)
        at org.apache.flink.runtime.jobmanager.TaskManagerFailsITCase.withFixture(TaskManagerFailsITCase.scala:34)
        at org.scalatest.WordSpecLike$class.invokeWithFixture$1(WordSpecLike.scala:950)
        at org.scalatest.WordSpecLike$$anonfun$runTest$1.apply(WordSpecLike.scala:962)
        at org.scalatest.WordSpecLike$$anonfun$runTest$1.apply(WordSpecLike.scala:962)
        at org.scalatest.SuperEngine.runTestImpl(Engine.scala:306)
        at org.scalatest.WordSpecLike$class.runTest(WordSpecLike.scala:962)
        at org.apache.flink.runtime.jobmanager.TaskManagerFailsITCase.runTest(TaskManagerFailsITCase.scala:34)
        at org.scalatest.WordSpecLike$$anonfun$runTests$1.apply(WordSpecLike.scala:1021)
        at org.scalatest.WordSpecLike$$anonfun$runTests$1.apply(WordSpecLike.scala:1021)
        at org.scalatest.SuperEngine$$anonfun$traverseSubNodes$1$1.apply(Engine.scala:413)
        at org.scalatest.SuperEngine$$anonfun$traverseSubNodes$1$1.apply(Engine.scala:401)
        at scala.collection.immutable.List.foreach(List.scala:318)
        at org.scalatest.SuperEngine.traverseSubNodes$1(Engine.scala:401)
        at org.scalatest.SuperEngine.org$scalatest$SuperEngine$$runTestsInBranch(Engine.scala:390)
        at org.scalatest.SuperEngine$$anonfun$traverseSubNodes$1$1.apply(Engine.scala:427)
        at org.scalatest.SuperEngine$$anonfun$traverseSubNodes$1$1.apply(Engine.scala:401)
        at scala.collection.immutable.List.foreach(List.scala:318)
        at org.scalatest.SuperEngine.traverseSubNodes$1(Engine.scala:401)
        at org.scalatest.SuperEngine.org$scalatest$SuperEngine$$runTestsInBranch(Engine.scala:396)
        at org.scalatest.SuperEngine.runTestsImpl(Engine.scala:483)
        at org.scalatest.WordSpecLike$class.runTests(WordSpecLike.scala:1021)
        at org.apache.flink.runtime.jobmanager.TaskManagerFailsITCase.runTests(TaskManagerFailsITCase.scala:34)
        at org.scalatest.Suite$class.run(Suite.scala:1424)
        at org.apache.flink.runtime.jobmanager.TaskManagerFailsITCase.org$scalatest$WordSpecLike$$super$run(TaskManagerFailsITCase.scala:34)
        at org.scalatest.WordSpecLike$$anonfun$run$1.apply(WordSpecLike.scala:1067)
        at org.scalatest.WordSpecLike$$anonfun$run$1.apply(WordSpecLike.scala:1067)
        at org.scalatest.SuperEngine.runImpl(Engine.scala:545)
        at org.scalatest.WordSpecLike$class.run(WordSpecLike.scala:1067)
        at org.apache.flink.runtime.jobmanager.TaskManagerFailsITCase.org$scalatest$BeforeAndAfterAll$$super$run(TaskManagerFailsITCase.scala:34)
        at org.scalatest.BeforeAndAfterAll$class.liftedTree1$1(BeforeAndAfterAll.scala:257)
        at org.scalatest.BeforeAndAfterAll$class.run(BeforeAndAfterAll.scala:256)
        at org.apache.flink.runtime.jobmanager.TaskManagerFailsITCase.run(TaskManagerFailsITCase.scala:34)
        at org.scalatest.junit.JUnitRunner.run(JUnitRunner.scala:99)
        at org.apache.maven.surefire.junit4.JUnit4Provider.execute(JUnit4Provider.java:264)
        at org.apache.maven.surefire.junit4.JUnit4Provider.executeTestSet(JUnit4Provider.java:153)
        at org.apache.maven.surefire.junit4.JUnit4Provider.invoke(JUnit4Provider.java:124)
        at org.apache.maven.surefire.booter.ForkedBooter.invokeProviderInSameClassLoader(ForkedBooter.java:200)
        at org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:153)
        at org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:103)
Caused by: java.util.concurrent.TimeoutException: Futures timed out after [200000 milliseconds]
        at scala.concurrent.impl.Promise$DefaultPromise.ready(Promise.scala:219)
        at scala.concurrent.impl.Promise$DefaultPromise.result(Promise.scala:223)
        at scala.concurrent.Await$$anonfun$result$1.apply(package.scala:107)
        at scala.concurrent.BlockContext$DefaultBlockContext$.blockOn(BlockContext.scala:53)
        at scala.concurrent.Await$.result(package.scala:107)
        at akka.remote.Remoting.start(Remoting.scala:173)
        ... 61 more
]
Tests run: 3, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 201.717 sec <<< FAILURE! - in org.apache.flink.runtime.jobmanager.TaskManagerFailsITCase
The JobManager should detect a failing task manager(org.apache.flink.runtime.jobmanager.TaskManagerFailsITCase)  Time elapsed: 200.111 sec  <<< ERROR!
java.util.concurrent.TimeoutException: Futures timed out after [200000 milliseconds]
        at scala.concurrent.impl.Promise$DefaultPromise.ready(Promise.scala:219)
        at scala.concurrent.impl.Promise$DefaultPromise.result(Promise.scala:223)
        at scala.concurrent.Await$$anonfun$result$1.apply(package.scala:107)
        at scala.concurrent.BlockContext$DefaultBlockContext$.blockOn(BlockContext.scala:53)
        at scala.concurrent.Await$.result(package.scala:107)
        at akka.remote.Remoting.start(Remoting.scala:173)
        at akka.remote.RemoteActorRefProvider.init(RemoteActorRefProvider.scala:184)
        at akka.actor.ActorSystemImpl._start$lzycompute(ActorSystem.scala:579)
        at akka.actor.ActorSystemImpl._start(ActorSystem.scala:577)
        at akka.actor.ActorSystemImpl.start(ActorSystem.scala:588)
        at akka.actor.ActorSystem$.apply(ActorSystem.scala:111)
        at akka.actor.ActorSystem$.apply(ActorSystem.scala:104)
        at akka.actor.ActorSystem$.create(ActorSystem.scala:66)
        at org.apache.flink.runtime.akka.AkkaUtils$.createActorSystem(AkkaUtils.scala:68)
        at org.apache.flink.runtime.minicluster.FlinkMiniCluster.startJobManagerActorSystem(FlinkMiniCluster.scala:91)
        at org.apache.flink.runtime.minicluster.FlinkMiniCluster.<init>(FlinkMiniCluster.scala:51)
        at org.apache.flink.runtime.testingUtils.TestingCluster.<init>(TestingCluster.scala:36)
        at org.apache.flink.runtime.testingUtils.TestingUtils$.startTestingClusterDeathWatch(TestingUtils.scala:106)
        at org.apache.flink.runtime.jobmanager.TaskManagerFailsITCase$$anonfun$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(TaskManagerFailsITCase.scala:48)
        at org.apache.flink.runtime.jobmanager.TaskManagerFailsITCase$$anonfun$1$$anonfun$apply$mcV$sp$1.apply(TaskManagerFailsITCase.scala:45)
        at org.apache.flink.runtime.jobmanager.TaskManagerFailsITCase$$anonfun$1$$anonfun$apply$mcV$sp$1.apply(TaskManagerFailsITCase.scala:45)
        at org.scalatest.Transformer$$anonfun$apply$1.apply$mcV$sp(Transformer.scala:22)
        at org.scalatest.OutcomeOf$class.outcomeOf(OutcomeOf.scala:85)
        at org.scalatest.OutcomeOf$.outcomeOf(OutcomeOf.scala:104)
        at org.scalatest.Transformer.apply(Transformer.scala:22)
        at org.scalatest.Transformer.apply(Transformer.scala:20)
        at org.scalatest.WordSpecLike$$anon$1.apply(WordSpecLike.scala:953)
        at org.scalatest.Suite$class.withFixture(Suite.scala:1122)
        at org.apache.flink.runtime.jobmanager.TaskManagerFailsITCase.withFixture(TaskManagerFailsITCase.scala:34)

Running org.apache.flink.runtime.operators.hash.ReusingReOpenableHashTableITCase
{code}
https://travis-ci.org/rmetzger/flink/jobs/50647683



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)