Submission Problem

[Matthias J. Sax]

Hi,

I just tried to submit Flink's Storm-Topology example via command line:

bin/flink run
~/workspace_flink/flink/flink-contrib/flink-storm-examples/target/WordCount-StormTopology.jar


However, I get a timeout and the program is not submitted. I tracked the
problem down to the following statement:

JobClient -> line 211:

> Future<Object> future = jobManagerGateway.ask(
>       new JobManagerMessages.SubmitJob(
>               jobGraph,
>               ListeningBehaviour.DETACHED // only receive the Acknowledge for 
> the job submission message
>       ),
>       timeout);
>                       
> result = Await.result(future, timeout);

The jobManagerGateway has the "value":
AkkaActorGateway(akka.tcp://flink@127.0.0.1:6123/user/jobmanager, null)

Not sure why Await.result does not return, as the value of
jobManagerGateway seems to be correct. Any idea?


-Matthias

signature.asc
Description: OpenPGP digital signature