Mailing-List: contact user-help@flink.incubator.apache.org; run by ezmlm
Precedence: bulk
Reply-To: user@flink.incubator.apache.org
Received-SPF: pass (athena.apache.org: domain of mathias.peters@gmx.org
 designates 212.227.17.20 as permitted sender)
Message-ID: <54AB90DC.4040301@gmx.org>
Date: Tue, 06 Jan 2015 08:38:04 +0100
From: Mathias Peters <mathias.peters@gmx.org>
User-Agent: Mozilla/5.0 (X11; Linux x86_64;
 rv:31.0) Gecko/20100101 Thunderbird/31.3.0
MIME-Version: 1.0
To: user@flink.incubator.apache.org
Subject: Re: Timeout when starting JobManager within Eclipse for debugging
 purposes
References: <54A92B1C.1060709@gmx.org>
	<CAC27z=NpPpJZSsa2MFht--rf_qm1pacv=Zg4ew81HQc98otg7A@mail.gmail.com>
 <CAC27z=MZHKqtJuiCQXkhPDkf4QiN7+dn2-KvJ8fae3aU157bhg@mail.gmail.com>
 <54AB904C.1000301@gmx.net>
In-Reply-To: <54AB904C.1000301@gmx.net>
Content-Type: text/plain; charset=utf-8
Content-Transfer-Encoding: 7bit

-----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 
>> <trohrmann@apache.org> 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 
>>> <mathias.peters@gmx.org> 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-----