Hi Mathias, the timeout exception means that the actor system could not be started. Usually this is the case if the hostname is not specified or if the hostname cannot be looked up. The best way to see what is happening is to turn on logging by providing a log4j.properties file with DEBUG logging. Additionally you can turn on akka logging by inserting akka.loglevel: DEBUG into the config file. A stripped down log4j config file looks the following:
log4j.rootLogger=DEBUG, A1 log4j.appender.A1=org.apache.log4j.ConsoleAppender log4j.appender.A1.layout=org.apache.log4j.PatternLayout log4j.appender.A1.layout.ConversionPattern=%-4r [%t] %-5p %c %x - %m%n I just tried to reproduce your problem on my machine, but I did not succeed. I started the JobManager with the config values jobmanager.rpc.address: localhost akka.loglevel: DEBUG For debugging in general, it is important that now all blocking RPC calls have now a timeout with the latest Akka changes. Thus, by blocking or slowing down a receiving thread too long might trigger a timeout exception on the receiving side. One can solve this problem by setting akka.ask.timeout in the config to a high value. I'll also increase the default timeout for local execution in one of the next commits. If you still have the debugging problem, could you then send me the log output. Greets, Till On Sun, Jan 4, 2015 at 12:59 PM, Mathias Peters <[email protected]> wrote: > -----BEGIN PGP SIGNED MESSAGE----- > Hash: SHA1 > > Hi everybody, > > I'd like to start the JobManager in debug mode from within Eclipse. I > used "--configDir PATH_TO_CONFDIR --executionMode local" as > parameters. In earlier versions that was enough. However, now I get a > timeout exeption that stems from the akka actor system. > > I am using the latest snapshot build 0.9 and the stack trace is at the > bottom of the mail. > > Am I missing something? Do I need to provide another parameter? > > Thanks a lot and regards > Mathias > > > Stack: > Exception in thread "main" java.util.concurrent.TimeoutException: > Futures timed out after [60000 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:180) > at > akka.remote.RemoteActorRefProvider.init(RemoteActorRefProvider.scala:184) > at akka.actor.ActorSystemImpl.liftedTree2$1(ActorSystem.scala:619) > at > akka.actor.ActorSystemImpl._start$lzycompute(ActorSystem.scala:616) > at akka.actor.ActorSystemImpl._start(ActorSystem.scala:616) > at akka.actor.ActorSystemImpl.start(ActorSystem.scala:633) > at akka.actor.ActorSystem$.apply(ActorSystem.scala:142) > at akka.actor.ActorSystem$.apply(ActorSystem.scala:119) > at akka.actor.ActorSystem$.create(ActorSystem.scala:67) > at > > org.apache.flink.runtime.akka.AkkaUtils$.createActorSystem(AkkaUtils.scala:52) > at > > org.apache.flink.runtime.akka.AkkaUtils$.createActorSystem(AkkaUtils.scala:40) > at > org.apache.flink.runtime.jobmanager.JobManager$.main(JobManager.scala:464) > at > org.apache.flink.runtime.jobmanager.JobManager.main(JobManager.scala) > > -----BEGIN PGP SIGNATURE----- > Version: GnuPG v1 > > iQEcBAEBAgAGBQJUqSscAAoJEHj0VWOtoCa75ZQH/0C58ucPLu8z9f0pgiGGsRfJ > 4+xsNXRjyepoPk9hFAcmVV4C0uDBW+F24rVJF7ZVA7lLWiDgy6sydLZXoKBgOXZm > Kgq2NrFvPzlFdIPs1tu885SDr8rKAw6tYhm21NDALb7kPNZGjtJv1QxgMN72n7vh > hkdzu4VqVut0qh8hPY7mdChIs4zxERoytg92vLv/oJ84nmsHtnOmB+SRwLNsO1d5 > zOqBd+I31bJGsB1TY+wtYc+AkqfMK1vMmYLqCgCW/vu6GWpvNOpljYic0vNDhkQU > 0i40uDcn4VVDONsyQhYXx3XbWyTjF2jr83tNyU4AKZklNIV1xJMQBZMvF9sZuXU= > =C3/B > -----END PGP SIGNATURE----- >
