Re: Could not build up connection to JobManager

;>> > >>>>>> > >>>>>>> On Mar 11, 2015, at 11:32 PM, Till Rohrmann > >>>>>> wrote: > >>>>>>> > >>>>>>> Hi Dulaj, > >>>>>>> > >>>&g

Re: Could not build up connection to JobManager

ct >>>>>>> to the JobManager using its IPv6 instead of IPv4. Akka is really >> picky >>>>>> when >>>>>>> it comes to remote address. If Akka binds to the FQDN, then other >>>>>>> ActorSystem which try to connect to it u

Re: Could not build up connection to JobManager

mes to remote address. If Akka binds to the FQDN, then other > > >>>> ActorSystem which try to connect to it using its IP address won't be > > >>>> successful. I assume that this might be a problem. I tried to fix > it. > > >>> You > >

Re: Could not build up connection to JobManager

ght be a problem. I tried to fix it. > >>> You > >>>> can find it here [1]. Could you please try it out by starting a local > >>>> cluster with the start-local.sh script. If it fails, could you please > >>> send > >>>> me all log files (

Re: Could not build up connection to JobManager

ils, could you please >>> send >>>> me all log files (client, jobmanager and taskmanager). Once we figured >>> out >>>> why the JobCilent does not connect, we can try to tackle the BlobServer >>>> issue. >>>> >>>> Cheers, >>>

Re: Could not build up connection to JobManager

. Once we figured >> out >> > why the JobCilent does not connect, we can try to tackle the BlobServer >> > issue. >> > >> > Cheers, >> > >> > Till >> > >> > [1] https://github.com/tillrohrmann/flink/tree/fixJobClient >> > &

Re: Could not build up connection to JobManager

he error message is, > >> > >> 21:06:01,521 WARN org.apache.hadoop.util.NativeCodeLoader > >> - Unable to load native-hadoop library for your platform... using > >> builtin-java classes where applicable > >> org.apache.flink.client.program

Re: Could not build up connection to JobManager

nt > > On Thu, Mar 5, 2015 at 4:40 PM, Dulaj Viduranga > wrote: > >> Hi, >> The error message is, >> >> 21:06:01,521 WARN org.apache.hadoop.util.NativeCodeLoader >> - Unable to load native-hadoop library for your platform... using >>

Re: Could not build up connection to JobManager

.NativeCodeLoader >- Unable to load native-hadoop library for your platform... using > builtin-java classes where applicable > org.apache.flink.client.program.ProgramInvocationException: Could not > build up connection to JobManager. > at org.apache.flink.client.pr

Re: Could not build up connection to JobManager

Hi, The error message is, 21:06:01,521 WARN org.apache.hadoop.util.NativeCodeLoader - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable org.apache.flink.client.program.ProgramInvocationException: Could not build up

Re: Could not build up connection to JobManager

What was the error when you tried to submit the job with "localhost"? The client log would be very helpful to understand the problem. Actually, the "localhost" in the code is only the fallback strategy if the job manager address could not be retrieved differently. On Thu, Mar 5, 2015 at 3:25 PM,

Re: Could not build up connection to JobManager

Glad I could help any way. :) When the address is set to “localhost” I cannot submit a job. It immediately fails. But the address is “127.0.0.1”, it is stuck a little whyle on DEPLOYING and the fails. Correct me if I’m wrong but I think since using the address, hardcoded in config file, won’t ha

Re: Could not build up connection to JobManager

Could you submit a job when you set the job manager address to "localhost"? I did not see any logging statements of received jobs. If you did, could you also send the logs of the client? The 0.0.0.0 to which the BlobServer binds works for me on my machine. I cannot remember that we had problems wi

Re: Could not build up connection to JobManager

But can you explain why did my fix solved it? > On Mar 5, 2015, at 5:50 PM, Stephan Ewen wrote: > > Hi Dulaj! > > Okay, the logs give us some insight. Both setups seem to look good in terms > of TaskManager and JobManager startup. > > In one of the logs (127.0.0.1) you submit a job. The job fa

Re: Could not build up connection to JobManager

Hi Dulaj! Okay, the logs give us some insight. Both setups seem to look good in terms of TaskManager and JobManager startup. In one of the logs (127.0.0.1) you submit a job. The job fails because the TaskManager cannot grab the JAR file from the JobManager. I think the problem is that the BLOB se

Re: Could not build up connection to JobManager

Hi, This is the log with setting “localhost” flink-Vidura-jobmanager-localhost.log And this is the log with setting “127.0.0.1” flink-Vidura-jobmanager-localhost.log

Re: Could not build up connection to JobManager

What does the jobmanager log says? I think Stephan added some more logging output which helps us to debug this problem. On Thu, Mar 5, 2015 at 9:36 AM, Dulaj Viduranga wrote: > Using start-locat.sh. > I’m using the original config yaml. I also tried changing jobmanager > address in config to “12

Re: Could not build up connection to JobManager

Using start-locat.sh. I’m using the original config yaml. I also tried changing jobmanager address in config to “127.0.0.1 but no luck. With my changes it works ok. The conf file follows. # Licensed to the Apache So

Re: Could not build up connection to JobManager

How did you start the flink cluster? Using the start-local.sh, the start-cluster.sh or starting the job manager and task managers individually using taskmanager.sh/jobmanager.sh. Could you maybe post the flink-conf.yaml file, you're using? With your changes, everything works, right? On Thu, Mar 5

Re: Could not build up connection to JobManager

Hi Till, I’m sorry. It doesn’t seem to solve the problem. The taskmanager still tries a 10.0.0.0/8 IP. Best regards. > On Mar 5, 2015, at 1:00 PM, Till Rohrmann wrote: > > Hi Dulaj, > > I looked through your commit and noticed that the JobClient might not be > listening on the right network i

Re: Could not build up connection to JobManager

Hi Dulaj, I looked through your commit and noticed that the JobClient might not be listening on the right network interface. Your commit seems to fix it. I just want to understand the problem properly and therefore I opened a branch with a small change. Could you try out whether this change would

Re: Could not build up connection to JobManager

The every change in the commit b7da22a is not required but I thought they are appropriate. > On Mar 5, 2015, at 8:11 AM, Dulaj Viduranga wrote: > > Hi, > I found many other places “localhost” is hard coded. I changed them in a > better way I think. I made a pull request. Please review. b7da22a

Re: Could not build up connection to JobManager

Hi, I found many other places “localhost” is hard coded. I changed them in a better way I think. I made a pull request. Please review. b7da22a > On Mar 4, 2015, at 8:17 PM, Stephan Ewen wrote: > > If I recall

Re: Could not build up connection to JobManager

If I recall correctly, we only hardcode "localhost" in the local mini cluster - do you think it is problematic there as well? Have you found any other places? On Mon, Mar 2, 2015 at 10:26 AM, Dulaj Viduranga wrote: > In some places of the code, "localhost" is hard coded. When it is resolved > b

[jira] [Created] (FLINK-1634) Fix "Could not build up connection to JobManager" issue on some systems

Dulaj Viduranga created FLINK-1634: -- Summary: Fix "Could not build up connection to JobManager" issue on some systems Key: FLINK-1634 URL: https://issues.apache.org/jira/browse/FLINK-1634

Re: Could not build up connection to JobManager

In some places of the code, "localhost" is hard coded. When it is resolved by the DNS, it is posible to be directed to a different IP other than 127.0.0.1 (like private range 10.0.0.0/8). I changed those places to 127.0.0.1 and it works like a charm. But hard coding 127.0.0.1 is not a good opt

Re: Could not build up connection to JobManager

not the easiest immigration > >>> experience, but the outcome is probably extremely valuable for the > project > >>> :-) > >>> > >>> Greetings, > >>> Stephan > >>> > >>> > >>> On Wed, Feb 25, 2015 at 4:03 PM, Dulaj Viduranga >

Re: Could not build up connection to JobManager

Wow, great. Can you tell us what the issue was? Am 02.03.2015 09:31 schrieb "Dulaj Viduranga" : > Hi, > I found the fix for this issue and I'll create a pull request in the > following day. >

Re: Could not build up connection to JobManager

Hi, I found the fix for this issue and I'll create a pull request in the following day.

Re: Could not build up connection to JobManager

>>> On Feb 26, 2015, at 12:46 AM, Stephan Ewen wrote: >>>>> >>>>> Addition: To check whether a port is reachable, I think the easiest >> thing >>>>> is to try and connect with a telnet client and see if the connection is >>>>> refused. >>>>> >>>&

Re: Could not build up connection to JobManager

;> Stephan >>> >>> >>> On Wed, Feb 25, 2015 at 4:03 PM, Dulaj Viduranga >>> wrote: >>> >>>> Hi, >>>> Sorry for the delay to reply on this issue. >>>> the jobmanager.rpc.address is set to “localhost” al

Re: Could not build up connection to JobManager

gt;>>> > >>>> Also, the 127.0.0.1 address cannot communicate to 10.216.177.146 > >>>> apparently. > >>>> > >>>> Can you help us debug this by checking the following: > >>>> > >>>> - Can you try and set "

Re: Could not build up connection to JobManager

3 or so) and see whether the port is >> reachable? >>>> >>>> We have recently updated how the Akka URLs are build, to work around a >>>> limitation in Akka. Seems that did not yet fully solve the issue. >>>> >>>&g

Re: Could not build up connection to JobManager

>>> Sorry for the delay to reply on this issue. > >>> the jobmanager.rpc.address is set to “localhost” already in conf.yaml. > >>> This can’t be an issue because the job manager web interface works fine > >>> which also runs on localhost > >>

Re: Could not build up connection to JobManager

ult in terminal. >>> >>> bin/flink run >>> /Users/Vidura/Documents/Development/flink/flink-dist/target/flink-0.9-SNAPSHOT-bin/flink-0.9-SNAPSHOT/examples/flink-java-examples-0.9-SNAPSHOT-WordCount.jar >>> /Users/Vidura/Documents/Development/flink/flink-dist/target/flink-0.9-SNAPSHOT-bin/flin

Re: Could not build up connection to JobManager

net >> >>>>>> or >> >>>>>>>> >> >>>>>>>>> curl) >> >>>>>>>> >> >>>>>>>>> Here is the log for jobManager >> >>>>>>>> >

Re: Could not build up connection to JobManager

t; builtin-java classes where applicable > org.apache.flink.client.program.ProgramInvocationException: Could not > build up connection to JobManager. > at org.apache.flink.client.program.Client.run(Client.java:327) > at org.apache.flink.client.program.

Re: Could not build up connection to JobManager

oaded jobs >>>> in >>>>>>>> >>>>>>>>> '/var/folders/3_/7gzbv7ks7q71lpm5d9hzrw2cgn/T/webclient-jobs', >>>>>>>> >>>>>>>>> plan-json-dumps in >>>>>>>> >>>>>>>>> '/var/folders/3_/7gzbv7ks7q71lpm5d9hzrw2cgn/T/webclient-plans'. >>>>>>>> >>>>>>>>> 23:22:31,934 INFO org.apache.flink.client.web.WebInterfaceServer >>>>>>>> >>>>>>>>> - Web-frontend will submit jobs to nephele job-manager on >>>>>>>> >>>>>>>> localhost, >>>>>>>> >>>>>>>>> port 6123. >>>>>>>> >>>>>>>>> 23:22:32,580 INFO akka.event.slf4j.Slf4jLogger >>>>>>>> >>>>>>>>> - Slf4jLogger started >>>>>>>> >>>>>>>>> 23:22:32,625 INFO Remoting >>>>>>>> >>>>>>>>> - Starting remoting >>>>>>>> >>>>>>>>> 23:22:32,838 INFO Remoting >>>>>>>> >>>>>>>>> - Remoting started; listening on addresses :[akka.tcp:// >>>>>>>> >>>>>>>> >>>>>>>>> JobsInfoServletActorSystem@127.0.0.1:51517] >>>>>>>> >>>>>>>>> 23:23:48,119 WARN Remoting >>>>>>>> >>>>>>>>> - Tried to associate with unreachable remote address [akka.tcp:// >>>>>>>> >>>>>>>> >>>>>>>>> flink@10.218.98.169:6123]. Address is now gated for 5000 ms, all >>>>>>>> >>>>>>>> messages >>>>>>>> >>>>>>>>> to this address will be delivered to dead letters. Reason: >>>> Operation >>>>>>>> >>>>>>>> timed >>>>>>>> >>>>>>>>> out: /10.218.98.169:6123 >>>>>>>> >>>>>>>>> 23:23:48,124 ERROR org.apache.flink.client.WebFrontend >>>>>>>> >>>>>>>>> - Unexpected exception: Could not find job manager at specified >>>>>>>> >>>>>>>>> address akka.flink@10.218.98.169:6123/user/jobmanager'>tcp:// >>>>>>>> flink@10.218.98.169:6123/user/jobmanager. >>>>>>>> >>>>>>>>> java.lang.RuntimeException: Could not find job manager at specified >>>>>>>> >>>>>>>>> address akka.flink@10.218.98.169:6123/user/jobmanager'>tcp:// >>>>>>>> flink@10.218.98.169:6123/user/jobmanager. >>>>>>>> >>>>>>>>> at >>>>>>>> >>>>>>>>> >>>>>>>> >>>>>>>> >>>>>> >>>> org.apache.flink.client.web.JobsInfoServlet.(JobsInfoServlet.java:82) >>>>>>>> >>>>>>>>> at >>>>>>>> >>>>>>>>> >>>>>>>> >>>>>>>> >>>>>>>> >>>>>> >>>> org.apache.flink.client.web.WebInterfaceServer.(WebInterfaceServer.java:158) >>>>>>>> >>>>>>>>> at org.apache.flink.client.WebFrontend.main(WebFrontend.java:74) >>>>>>>> >>>>>>>>> >>>>>>>> >>>>>>>>> >>>>>>>> >>>>>>>>>> On Feb 23, 2015, at 11:46 PM, Robert Metzger >>>> >>>>>>>> >>>>>>>>> wrote: >>>>>>>> >>>>>>>>>> >>>>>>>> >>>>>>>>>> Hi, >>>>>>>> >>>>>>>>>> you said in the other email thread that the error only occurs for >>>>>>>> >>>>>>>>>> Wordcount, not for Kmeans. >>>>>>>> >>>>>>>>>> Can you copy me the commands for both examples? >>>>>>>> >>>>>>>>>> I can not really believe that there is a difference between the >>>> two >>>>>>>> >>>>>>>> jobs. >>>>>>>> >>>>>>>>>> >>>>>>>> >>>>>>>>>> Can you also send us the contents of the jobmanager log file? >>>>>>>> >>>>>>>>>> >>>>>>>> >>>>>>>>>> Best, >>>>>>>> >>>>>>>>>> Robert >>>>>>>> >>>>>>>>>> >>>>>>>> >>>>>>>>>> >>>>>>>> >>>>>>>>>> On Mon, Feb 23, 2015 at 6:04 PM, Dulaj Viduranga < >>>>>> vidura...@icloud.com >>>>>>>> >>>>>>>> >>>>>>>>> >>>>>>>> >>>>>>>>>> wrote: >>>>>>>> >>>>>>>>>> >>>>>>>> >>>>>>>>>>> I’m getting "Could not build up connection to JobManager.” When i >>>>>>>> >>>>>>>> tried >>>>>>>> >>>>>>>>> to >>>>>>>> >>>>>>>>>>> run the wordCount example. Can anyone help? >>>>>>>> >>>>>>>>>>> >>>>>>>> >>>>>>>>>>> Dulaj >>>>>>>> >>>>>>>>> >>>>>>>> >>>>>>>>> >>>>>>>> >>>>>>>> >>>>>> >>>>>> >>>> >>>> >>> >>

Re: Could not build up connection to JobManager

gt; >>> >>>>> plan-json-dumps in >>> >>>> >>> >>>>> '/var/folders/3_/7gzbv7ks7q71lpm5d9hzrw2cgn/T/webclient-plans'. >>> >>>> >>> >>>>> 23:22:31,934 INFO org.apache.flink.client.web.WebInterfaceServ

Re: Could not build up connection to JobManager

>>>>> - Slf4jLogger started >> >>>> >> >>>>> 23:22:32,625 INFO Remoting >> >>>> >> >>>>> - Starting remoting >> >>>> >> >>>>> 23:22:32,838 INFO Remoting >> >>>> >> >>>>> - Remoting started; listening on addresses :[akka.tcp:// >> >>>> >> >>>> >> >>>>> JobsInfoServletActorSystem@127.0.0.1:51517] >> >>>> >> >>>>> 23:23:48,119 WARN Remoting >> >>>> >> >>>>> - Tried to associate with unreachable remote address [akka.tcp:// >> >>>> >> >>>> >> >>>>> flink@10.218.98.169:6123]. Address is now gated for 5000 ms, all >> >>>> >> >>>> messages >> >>>> >> >>>>> to this address will be delivered to dead letters. Reason: Operation >> >>>> >> >>>> timed >> >>>> >> >>>>> out: /10.218.98.169:6123 >> >>>> >> >>>>> 23:23:48,124 ERROR org.apache.flink.client.WebFrontend >> >>>> >> >>>>> - Unexpected exception: Could not find job manager at specified >> >>>> >> >>>>> address akka.flink@10.218.98.169:6123/user/jobmanager'>tcp:// >> >>>> flink@10.218.98.169:6123/user/jobmanager. >> >>>> >> >>>>> java.lang.RuntimeException: Could not find job manager at specified >> >>>> >> >>>>> address akka.flink@10.218.98.169:6123/user/jobmanager'>tcp:// >> >>>> flink@10.218.98.169:6123/user/jobmanager. >> >>>> >> >>>>> at >> >>>> >> >>>>> >> >>>> >> >>>> >> >> >> org.apache.flink.client.web.JobsInfoServlet.(JobsInfoServlet.java:82) >> >>>> >> >>>>> at >> >>>> >> >>>>> >> >>>> >> >>>> >> >>>> >> >> >> org.apache.flink.client.web.WebInterfaceServer.(WebInterfaceServer.java:158) >> >>>> >> >>>>> at org.apache.flink.client.WebFrontend.main(WebFrontend.java:74) >> >>>> >> >>>>> >> >>>> >> >>>>> >> >>>> >> >>>>>> On Feb 23, 2015, at 11:46 PM, Robert Metzger >> >>>> >> >>>>> wrote: >> >>>> >> >>>>>> >> >>>> >> >>>>>> Hi, >> >>>> >> >>>>>> you said in the other email thread that the error only occurs for >> >>>> >> >>>>>> Wordcount, not for Kmeans. >> >>>> >> >>>>>> Can you copy me the commands for both examples? >> >>>> >> >>>>>> I can not really believe that there is a difference between the two >> >>>> >> >>>> jobs. >> >>>> >> >>>>>> >> >>>> >> >>>>>> Can you also send us the contents of the jobmanager log file? >> >>>> >> >>>>>> >> >>>> >> >>>>>> Best, >> >>>> >> >>>>>> Robert >> >>>> >> >>>>>> >> >>>> >> >>>>>> >> >>>> >> >>>>>> On Mon, Feb 23, 2015 at 6:04 PM, Dulaj Viduranga < >> >> vidura...@icloud.com >> >>>> >> >>>> >> >>>>> >> >>>> >> >>>>>> wrote: >> >>>> >> >>>>>> >> >>>> >> >>>>>>> I’m getting "Could not build up connection to JobManager.” When i >> >>>> >> >>>> tried >> >>>> >> >>>>> to >> >>>> >> >>>>>>> run the wordCount example. Can anyone help? >> >>>> >> >>>>>>> >> >>>> >> >>>>>>> Dulaj >> >>>> >> >>>>> >> >>>> >> >>>>> >> >>>> >> >>>> >> >> >> >> >> >> >

Re: Could not build up connection to JobManager

; - Remoting started; listening on addresses :[akka.tcp:// > >>>> > >>>> > >>>>> JobsInfoServletActorSystem@127.0.0.1:51517] > >>>> > >>>>> 23:23:48,119 WARN Remoting > >>>> > >>>>> - Tried to associate with unreachable remote address [akka.tcp:// > >>>> > >>>> > >>>>> flink@10.218.98.169:6123]. Address is now gated for 5000 ms, all > >>>> > >>>> messages > >>>> > >>>>> to this address will be delivered to dead letters. Reason: Operation > >>>> > >>>> timed > >>>> > >>>>> out: /10.218.98.169:6123 > >>>> > >>>>> 23:23:48,124 ERROR org.apache.flink.client.WebFrontend > >>>> > >>>>> - Unexpected exception: Could not find job manager at specified > >>>> > >>>>> address akka.flink@10.218.98.169:6123/user/jobmanager'>tcp:// > >>>> flink@10.218.98.169:6123/user/jobmanager. > >>>> > >>>>> java.lang.RuntimeException: Could not find job manager at specified > >>>> > >>>>> address akka.flink@10.218.98.169:6123/user/jobmanager'>tcp:// > >>>> flink@10.218.98.169:6123/user/jobmanager. > >>>> > >>>>> at > >>>> > >>>>> > >>>> > >>>> > >> > org.apache.flink.client.web.JobsInfoServlet.(JobsInfoServlet.java:82) > >>>> > >>>>> at > >>>> > >>>>> > >>>> > >>>> > >>>> > >> > org.apache.flink.client.web.WebInterfaceServer.(WebInterfaceServer.java:158) > >>>> > >>>>> at org.apache.flink.client.WebFrontend.main(WebFrontend.java:74) > >>>> > >>>>> > >>>> > >>>>> > >>>> > >>>>>> On Feb 23, 2015, at 11:46 PM, Robert Metzger > >>>> > >>>>> wrote: > >>>> > >>>>>> > >>>> > >>>>>> Hi, > >>>> > >>>>>> you said in the other email thread that the error only occurs for > >>>> > >>>>>> Wordcount, not for Kmeans. > >>>> > >>>>>> Can you copy me the commands for both examples? > >>>> > >>>>>> I can not really believe that there is a difference between the two > >>>> > >>>> jobs. > >>>> > >>>>>> > >>>> > >>>>>> Can you also send us the contents of the jobmanager log file? > >>>> > >>>>>> > >>>> > >>>>>> Best, > >>>> > >>>>>> Robert > >>>> > >>>>>> > >>>> > >>>>>> > >>>> > >>>>>> On Mon, Feb 23, 2015 at 6:04 PM, Dulaj Viduranga < > >> vidura...@icloud.com > >>>> > >>>> > >>>>> > >>>> > >>>>>> wrote: > >>>> > >>>>>> > >>>> > >>>>>>> I’m getting "Could not build up connection to JobManager.” When i > >>>> > >>>> tried > >>>> > >>>>> to > >>>> > >>>>>>> run the wordCount example. Can anyone help? > >>>> > >>>>>>> > >>>> > >>>>>>> Dulaj > >>>> > >>>>> > >>>> > >>>>> > >>>> > >>>> > >> > >> > >

Re: Could not build up connection to JobManager

; >>>>> flink@10.218.98.169:6123]. Address is now gated for 5000 ms, all >>>> >>>> messages >>>> >>>>> to this address will be delivered to dead letters. Reason: Operation >>>> >>>> timed >>>> >>>>> out: /10.218.98.169:6123 >>>> >>>>> 23:23:48,124 ERROR org.apache.flink.client.WebFrontend >>>> >>>>> - Unexpected exception: Could not find job manager at specified >>>> >>>>> address akka.flink@10.218.98.169:6123/user/jobmanager'>tcp:// >>>> flink@10.218.98.169:6123/user/jobmanager. >>>> >>>>> java.lang.RuntimeException: Could not find job manager at specified >>>> >>>>> address akka.flink@10.218.98.169:6123/user/jobmanager'>tcp:// >>>> flink@10.218.98.169:6123/user/jobmanager. >>>> >>>>> at >>>> >>>>> >>>> >>>> >> org.apache.flink.client.web.JobsInfoServlet.(JobsInfoServlet.java:82) >>>> >>>>> at >>>> >>>>> >>>> >>>> >>>> >> org.apache.flink.client.web.WebInterfaceServer.(WebInterfaceServer.java:158) >>>> >>>>> at org.apache.flink.client.WebFrontend.main(WebFrontend.java:74) >>>> >>>>> >>>> >>>>> >>>> >>>>>> On Feb 23, 2015, at 11:46 PM, Robert Metzger >>>> >>>>> wrote: >>>> >>>>>> >>>> >>>>>> Hi, >>>> >>>>>> you said in the other email thread that the error only occurs for >>>> >>>>>> Wordcount, not for Kmeans. >>>> >>>>>> Can you copy me the commands for both examples? >>>> >>>>>> I can not really believe that there is a difference between the two >>>> >>>> jobs. >>>> >>>>>> >>>> >>>>>> Can you also send us the contents of the jobmanager log file? >>>> >>>>>> >>>> >>>>>> Best, >>>> >>>>>> Robert >>>> >>>>>> >>>> >>>>>> >>>> >>>>>> On Mon, Feb 23, 2015 at 6:04 PM, Dulaj Viduranga < >> vidura...@icloud.com >>>> >>>> >>>>> >>>> >>>>>> wrote: >>>> >>>>>> >>>> >>>>>>> I’m getting "Could not build up connection to JobManager.” When i >>>> >>>> tried >>>> >>>>> to >>>> >>>>>>> run the wordCount example. Can anyone help? >>>> >>>>>>> >>>> >>>>>>> Dulaj >>>> >>>>> >>>> >>>>> >>>> >>>> >> >>

Re: Could not build up connection to JobManager

0.218.98.169:6123 >>> >>>> 23:23:48,124 ERROR org.apache.flink.client.WebFrontend >>> >>>> - Unexpected exception: Could not find job manager at specified >>> >>>> address akka.flink@10.218.98.169:6123/user/jobmanager'>tcp:// >>> flink@10.218.98.169:6123/user/jobmanager. >>> >>>> java.lang.RuntimeException: Could not find job manager at specified >>> >>>> address akka.flink@10.218.98.169:6123/user/jobmanager'>tcp:// >>> flink@10.218.98.169:6123/user/jobmanager. >>> >>>> at >>> >>>> >>> >>> org.apache.flink.client.web.JobsInfoServlet.(JobsInfoServlet.java:82) >>> >>>> at >>> >>>> >>> >>> >>> org.apache.flink.client.web.WebInterfaceServer.(WebInterfaceServer.java:158) >>> >>>> at org.apache.flink.client.WebFrontend.main(WebFrontend.java:74) >>> >>>> >>> >>>> >>> >>>>> On Feb 23, 2015, at 11:46 PM, Robert Metzger >>> >>>> wrote: >>> >>>>> >>> >>>>> Hi, >>> >>>>> you said in the other email thread that the error only occurs for >>> >>>>> Wordcount, not for Kmeans. >>> >>>>> Can you copy me the commands for both examples? >>> >>>>> I can not really believe that there is a difference between the two >>> >>> jobs. >>> >>>>> >>> >>>>> Can you also send us the contents of the jobmanager log file? >>> >>>>> >>> >>>>> Best, >>> >>>>> Robert >>> >>>>> >>> >>>>> >>> >>>>> On Mon, Feb 23, 2015 at 6:04 PM, Dulaj Viduranga >> >>> >>>> >>> >>>>> wrote: >>> >>>>> >>> >>>>>> I’m getting "Could not build up connection to JobManager.” When i >>> >>> tried >>> >>>> to >>> >>>>>> run the wordCount example. Can anyone help? >>> >>>>>> >>> >>>>>> Dulaj >>> >>>> >>> >>>> >>> >>> >

Re: Could not build up connection to JobManager

org.apache.flink.client.WebFrontend > >> > >>> - Unexpected exception: Could not find job manager at specified > >> > >>> address akka.flink@10.218.98.169:6123/user/jobmanager'>tcp:// > >> flink@10.218.98.169:6123/user/jobmanager. > >> > >>> java.lang.RuntimeException: Could not find job manager at specified > >> > >>> address akka.flink@10.218.98.169:6123/user/jobmanager'>tcp:// > >> flink@10.218.98.169:6123/user/jobmanager. > >> > >>> at > >> > >>> > >> > >> > org.apache.flink.client.web.JobsInfoServlet.(JobsInfoServlet.java:82) > >> > >>> at > >> > >>> > >> > >> > >> > org.apache.flink.client.web.WebInterfaceServer.(WebInterfaceServer.java:158) > >> > >>> at org.apache.flink.client.WebFrontend.main(WebFrontend.java:74) > >> > >>> > >> > >>> > >> > >>>> On Feb 23, 2015, at 11:46 PM, Robert Metzger > >> > >>> wrote: > >> > >>>> > >> > >>>> Hi, > >> > >>>> you said in the other email thread that the error only occurs for > >> > >>>> Wordcount, not for Kmeans. > >> > >>>> Can you copy me the commands for both examples? > >> > >>>> I can not really believe that there is a difference between the two > >> > >> jobs. > >> > >>>> > >> > >>>> Can you also send us the contents of the jobmanager log file? > >> > >>>> > >> > >>>> Best, > >> > >>>> Robert > >> > >>>> > >> > >>>> > >> > >>>> On Mon, Feb 23, 2015 at 6:04 PM, Dulaj Viduranga < > vidura...@icloud.com > >> > >> > >>> > >> > >>>> wrote: > >> > >>>> > >> > >>>>> I’m getting "Could not build up connection to JobManager.” When i > >> > >> tried > >> > >>> to > >> > >>>>> run the wordCount example. Can anyone help? > >> > >>>>> > >> > >>>>> Dulaj > >> > >>> > >> > >>> > >> > >> > >

Re: Could not build up connection to JobManager

gt;>> address akka.flink@10.218.98.169:6123/user/jobmanager'>tcp:// >> flink@10.218.98.169:6123/user/jobmanager. >> >>> java.lang.RuntimeException: Could not find job manager at specified >> >>> address akka.flink@10.218.98.169:6123/user/job

Re: Could not build up connection to JobManager

/user/jobmanager'>tcp:// >> flink@10.218.98.169:6123/user/jobmanager. >> >>> at >> >>> >> >> org.apache.flink.client.web.JobsInfoServlet.(JobsInfoServlet.java:82) >> >>> at >> >>> >> >> >> org.apache.flink.client.web.WebInterfaceServer.(WebInterfaceServer.java:158) >> >>> at org.apache.flink.client.WebFrontend.main(WebFrontend.java:74) >> >>> >> >>> >> >>>> On Feb 23, 2015, at 11:46 PM, Robert Metzger >> >>> wrote: >> >>>> >> >>>> Hi, >> >>>> you said in the other email thread that the error only occurs for >> >>>> Wordcount, not for Kmeans. >> >>>> Can you copy me the commands for both examples? >> >>>> I can not really believe that there is a difference between the two >> >> jobs. >> >>>> >> >>>> Can you also send us the contents of the jobmanager log file? >> >>>> >> >>>> Best, >> >>>> Robert >> >>>> >> >>>> >> >>>> On Mon, Feb 23, 2015 at 6:04 PM, Dulaj Viduranga > >> >>> >> >>>> wrote: >> >>>> >> >>>>> I’m getting "Could not build up connection to JobManager.” When i >> >> tried >> >>> to >> >>>>> run the wordCount example. Can anyone help? >> >>>>> >> >>>>> Dulaj >> >>> >> >>> >> >>

Re: Could not build up connection to JobManager

; > > > > > org.apache.flink.client.web.WebInterfaceServer.(WebInterfaceServer.java:158) > > > at org.apache.flink.client.WebFrontend.main(WebFrontend.java:74) > > > > > > > > > > On Feb 23, 2015, at 11:46 PM, Robert Metzger > > > wrote: > > > > > > > > Hi, > > > > you said in the other email thread that the error only occurs for > > > > Wordcount, not for Kmeans. > > > > Can you copy me the commands for both examples? > > > > I can not really believe that there is a difference between the two > > jobs. > > > > > > > > Can you also send us the contents of the jobmanager log file? > > > > > > > > Best, > > > > Robert > > > > > > > > > > > > On Mon, Feb 23, 2015 at 6:04 PM, Dulaj Viduranga > > > > > > > wrote: > > > > > > > >> I’m getting "Could not build up connection to JobManager.” When i > > tried > > > to > > > >> run the wordCount example. Can anyone help? > > > >> > > > >> Dulaj > > > > > > > >

Re: Could not build up connection to JobManager

e: > > > > Hi, > > you said in the other email thread that the error only occurs for > > Wordcount, not for Kmeans. > > Can you copy me the commands for both examples? > > I can not really believe that there is a difference between the two jobs. > > >

Re: Could not build up connection to JobManager

the error only occurs for > > > Wordcount, not for Kmeans. > > > Can you copy me the commands for both examples? > > > I can not really believe that there is a difference between the two > jobs. > > > > > > Can you also send us the contents of the jobmanager log file? > > > > > > Best, > > > Robert > > > > > > > > > On Mon, Feb 23, 2015 at 6:04 PM, Dulaj Viduranga > > > > wrote: > > > > > >> I’m getting "Could not build up connection to JobManager.” When i > tried > > to > > >> run the wordCount example. Can anyone help? > > >> > > >> Dulaj > > > > >

Re: Could not build up connection to JobManager

elieve that there is a difference between the two jobs. > > > > Can you also send us the contents of the jobmanager log file? > > > > Best, > > Robert > > > > > > On Mon, Feb 23, 2015 at 6:04 PM, Dulaj Viduranga > > wrote: > > > >> I’m getting "Could not build up connection to JobManager.” When i tried > to > >> run the wordCount example. Can anyone help? > >> > >> Dulaj > >

Re: Could not build up connection to JobManager

not for Kmeans. > Can you copy me the commands for both examples? > I can not really believe that there is a difference between the two jobs. > > Can you also send us the contents of the jobmanager log file? > > Best, > Robert > > > On Mon, Feb 23, 2015 at 6:04 PM, Dul

Re: Could not build up connection to JobManager

On Mon, Feb 23, 2015 at 6:04 PM, Dulaj Viduranga wrote: > I’m getting "Could not build up connection to JobManager.” When i tried to > run the wordCount example. Can anyone help? > > Dulaj

Could not build up connection to JobManager

I’m getting "Could not build up connection to JobManager.” When i tried to run the wordCount example. Can anyone help? Dulaj

Re: Could not build up connection to JobManager - Error

> this error. I have already started FLINK with bin/start-local.sh. Can >>> someone please help? >>> >>> 21:01:19,898 WARN org.apache.hadoop.util.NativeCodeLoader >>> - Unable to load native-hadoop library for your platform... using >

Re: Could not build up connection to JobManager - Error

op.util.NativeCodeLoader >> - Unable to load native-hadoop library for your platform... using >> builtin-java classes where applicable >> org.apache.flink.client.program.ProgramInvocationException: Could not >> build up connection to JobManager. >>at org.apache.

Re: Could not build up connection to JobManager - Error

uiltin-java classes where applicable > org.apache.flink.client.program.ProgramInvocationException: Could not > build up connection to JobManager. > at org.apache.flink.client.program.Client.run(Client.java:327) > at org.apache.flink.client.program.Client.run(Client.java:306) > at org.apache.flink.clie

Could not build up connection to JobManager - Error

platform... using builtin-java classes where applicable org.apache.flink.client.program.ProgramInvocationException: Could not build up connection to JobManager. at org.apache.flink.client.program.Client.run(Client.java:327) at org.apache.flink.client.program.Client.run(Client.java:306