[
https://issues.apache.org/jira/browse/FLINK-1540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-1540.
---------------------------------
Resolution: Fixed
Fix Version/s: 0.9
Fixed by dropping the older Akka version after shading conflicting dependencies.
Fixed as of 84e76f4d3274e07176f7377b7b739b6f180c6296
> 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
> Fix For: 0.9
>
>
> {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)
