Mathias, That makes total sense. Do you want to open an issue for that?
In addition: what prevents us from allowing to start a local mode job manager without a config? Stephan Am 06.01.2015 08:38 schrieb "Mathias Peters" <[email protected]>: > -----BEGIN PGP SIGNED MESSAGE----- > Hash: SHA1 > > Hi Till, > > turned out I chose the wrong confDir-Path. The directory didn't > contain the flink-conf.yaml. ;) > > AkkaUtils tried to create the ActorSystem anyway so I didn't realize > at first. > I suggest a warning in case the conf files cannot be found. > > Thanks for the reply! > > Regards > Mathias > > > > > > On 05.01.2015 16:59, Till Rohrmann wrote: > >> I forgot to mention that the parameters you used are perfectly > >> correct. > > > >> On Mon, Jan 5, 2015 at 4:57 PM, Till Rohrmann > >> <[email protected]> wrote: > > > >>> 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: > >>> > >> 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 > > iQEcBAEBAgAGBQJUq5DcAAoJEHj0VWOtoCa7vPgIAN0Kif/27LNfq4Un0QD4klY2 > nvsC3ulM2/AS0IgRYLzN4mJBCMV2+GzsA2rqbnTNzh6CfscYK3ij+TLUGt5+Ttju > wwtfOjiSgri5ySVuiITHHb4OpTG+ZUi0d6pHZ9KVBf82Z98tHDzxncaqn1vN1r1a > wFLLUprDfjKlOBMaQ8lXrNj+ysglpuLN33IFv2evW8ZliaPZbnj6JroB+SETotLO > OWw7YBHGRqPDcQmXh/fOkFT6PryN63OgQ89yB9oIoLp45RNmDOm0RILzKWXaM9Ah > eOAVJ9ln7MHeyxCM6e2dQz3FOGFC81F6BTW0vFXLBedGAcDZKiG18jvNWjABQJ0= > =fcsi > -----END PGP SIGNATURE----- >
