Hi,
I’m thinking I’m doing something wrong. After setting jobManager address to
127.0.0.1, I can run kmeans example (java -cp
../examples/flink-java-examples-0.9-SNAPSHOT-KMeans.jar
org.apache.flink.examples.java.clustering.util.KMeansDataGenerator 500 10 0.08)
But I can’t run word count example (bin/flink run
./examples/flink-java-examples-0.9-SNAPSHOT-WordCount.jar
file:'///Users/Vidura/Documents/Development/flink/flink-dist/target/flink-0.9-SNAPSHOT-bin/flink-0.9-SNAPSHOT/hamlet.txt'
file:'///Users/Vidura/Documents/Development/flink/flink-dist/target/flink-0.9-SNAPSHOT-bin/flink-0.9-SNAPSHOT/count.txt’)
I’m not sure whether I’m running it wrong
> On Feb 26, 2015, at 9:03 PM, Dulaj Viduranga <vidura...@icloud.com> wrote:
>
> Hi,
> It’s great to help out. :)
>
> Setting 127.0.0.1 instead of “localhost” in jobmanager.rpc.address,
> helped to build the connection to the jobmanager. Apparently localhost
> resolving is different in webclient and the jobmanager. I think it’s good to
> set "jobmanager.rpc.address: 127.0.0.1" in future builds.
> But then I get this error when I tried to run examples. I don’t know if
> I should move this issue to another thread. If so please tell me.
>
> 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/flink-0.9-SNAPSHOT/hamlet.txt
> $FLINK_DIRECTORY/count
>
>
> 20:46:21,998 WARN org.apache.hadoop.util.NativeCodeLoader
> - Unable to load native-hadoop library for your platform... using
> builtin-java classes where applicable
> 02/26/2015 20:46:23 Job execution switched to status RUNNING.
> 02/26/2015 20:46:23 CHAIN DataSource (at getTextDataSet(WordCount.java:141)
> (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at
> main(WordCount.java:69)) -> Combine(SUM(1), at main(WordCount.java:72)(1/1)
> switched to SCHEDULED
> 02/26/2015 20:46:23 CHAIN DataSource (at getTextDataSet(WordCount.java:141)
> (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at
> main(WordCount.java:69)) -> Combine(SUM(1), at main(WordCount.java:72)(1/1)
> switched to DEPLOYING
> 02/26/2015 20:48:03 CHAIN DataSource (at getTextDataSet(WordCount.java:141)
> (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at
> main(WordCount.java:69)) -> Combine(SUM(1), at main(WordCount.java:72)(1/1)
> switched to FAILED
> akka.pattern.AskTimeoutException: Ask timed out on
> [Actor[akka://flink/user/taskmanager#-1628133761]] after [100000 ms]
> at
> akka.pattern.PromiseActorRef$$anonfun$1.apply$mcV$sp(AskSupport.scala:333)
> at akka.actor.Scheduler$$anon$7.run(Scheduler.scala:117)
> at
> scala.concurrent.Future$InternalCallbackExecutor$.scala$concurrent$Future$InternalCallbackExecutor$$unbatchedExecute(Future.scala:694)
> at
> scala.concurrent.Future$InternalCallbackExecutor$.execute(Future.scala:691)
> at
> akka.actor.LightArrayRevolverScheduler$TaskHolder.executeTask(Scheduler.scala:467)
> at
> akka.actor.LightArrayRevolverScheduler$$anon$8.executeBucket$1(Scheduler.scala:419)
> at
> akka.actor.LightArrayRevolverScheduler$$anon$8.nextTick(Scheduler.scala:423)
> at
> akka.actor.LightArrayRevolverScheduler$$anon$8.run(Scheduler.scala:375)
> at java.lang.Thread.run(Thread.java:745)
>
> 02/26/2015 20:48:03 Job execution switched to status FAILING.
> 02/26/2015 20:48:03 Reduce (SUM(1), at main(WordCount.java:72)(1/1)
> switched to CANCELED
> 02/26/2015 20:48:03 DataSink(CsvOutputFormat (path:
> /Users/Vidura/Documents/Development/flink/flink-dist/target/flink-0.9-SNAPSHOT-bin/flink-0.9-SNAPSHOT/count,
> delimiter: ))(1/1) switched to CANCELED
> 02/26/2015 20:48:03 Job execution switched to status FAILED.
> org.apache.flink.client.program.ProgramInvocationException: The program
> execution failed.
> at org.apache.flink.client.program.Client.run(Client.java:344)
> at org.apache.flink.client.program.Client.run(Client.java:306)
> at org.apache.flink.client.program.Client.run(Client.java:300)
> at
> org.apache.flink.client.program.ContextEnvironment.execute(ContextEnvironment.java:55)
> at
> org.apache.flink.examples.java.wordcount.WordCount.main(WordCount.java:82)
> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> at java.lang.reflect.Method.invoke(Method.java:483)
> at
> org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:437)
> at
> org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:353)
> at org.apache.flink.client.program.Client.run(Client.java:250)
> at
> org.apache.flink.client.CliFrontend.executeProgram(CliFrontend.java:371)
> at org.apache.flink.client.CliFrontend.run(CliFrontend.java:344)
> at
> org.apache.flink.client.CliFrontend.parseParameters(CliFrontend.java:1087)
> at org.apache.flink.client.CliFrontend.main(CliFrontend.java:1114)
> Caused by: org.apache.flink.runtime.client.JobExecutionException: Job
> execution failed.
> at
> org.apache.flink.runtime.jobmanager.JobManager$$anonfun$receiveWithLogMessages$1.applyOrElse(JobManager.scala:284)
> at
> scala.runtime.AbstractPartialFunction$mcVL$sp.apply$mcVL$sp(AbstractPartialFunction.scala:33)
> at
> scala.runtime.AbstractPartialFunction$mcVL$sp.apply(AbstractPartialFunction.scala:33)
> at
> scala.runtime.AbstractPartialFunction$mcVL$sp.apply(AbstractPartialFunction.scala:25)
> at
> org.apache.flink.runtime.ActorLogMessages$$anon$1.apply(ActorLogMessages.scala:37)
> at
> org.apache.flink.runtime.ActorLogMessages$$anon$1.apply(ActorLogMessages.scala:30)
> at scala.PartialFunction$class.applyOrElse(PartialFunction.scala:118)
> at
> org.apache.flink.runtime.ActorLogMessages$$anon$1.applyOrElse(ActorLogMessages.scala:30)
> at akka.actor.Actor$class.aroundReceive(Actor.scala:465)
> at
> org.apache.flink.runtime.jobmanager.JobManager.aroundReceive(JobManager.scala:88)
> at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516)
> at akka.actor.ActorCell.invoke(ActorCell.scala:487)
> at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254)
> at akka.dispatch.Mailbox.run(Mailbox.scala:221)
> at akka.dispatch.Mailbox.exec(Mailbox.scala:231)
> at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
> at
> scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
> at
> scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
> at
> scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
> Caused by: akka.pattern.AskTimeoutException: Ask timed out on
> [Actor[akka://flink/user/taskmanager#-1628133761]] after [100000 ms]
> at
> akka.pattern.PromiseActorRef$$anonfun$1.apply$mcV$sp(AskSupport.scala:333)
> at akka.actor.Scheduler$$anon$7.run(Scheduler.scala:117)
> at
> scala.concurrent.Future$InternalCallbackExecutor$.scala$concurrent$Future$InternalCallbackExecutor$$unbatchedExecute(Future.scala:694)
> at
> scala.concurrent.Future$InternalCallbackExecutor$.execute(Future.scala:691)
> at
> akka.actor.LightArrayRevolverScheduler$TaskHolder.executeTask(Scheduler.scala:467)
> at
> akka.actor.LightArrayRevolverScheduler$$anon$8.executeBucket$1(Scheduler.scala:419)
> at
> akka.actor.LightArrayRevolverScheduler$$anon$8.nextTick(Scheduler.scala:423)
> at
> akka.actor.LightArrayRevolverScheduler$$anon$8.run(Scheduler.scala:375)
> at java.lang.Thread.run(Thread.java:745)
>
> The exception above occurred while trying to run your command.
>
>
>> On Feb 26, 2015, at 12:46 AM, Stephan Ewen <se...@apache.org> 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.
>>
>> On Wed, Feb 25, 2015 at 8:15 PM, Stephan Ewen <se...@apache.org> wrote:
>>
>>> Okay, the problem seems to be that even though both the client and the
>>> jobmanager use "localhost" as the host name, they resolve this to different
>>> IP addresses: In one case 127.0.0.1 in the other case 10.216.177.146
>>>
>>> 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 "jobmanager.rpc.address" to 127.0.0.1 and see if
>>> that solves it?
>>> - Can you try and set "jobmanager.rpc.address" to the other address
>>> (10.216.177.146
>>> or so) and see if that solves it?
>>> - Can you do "start-cluster.sh", rather than "start-local.sh" and see
>>> whether the webfrontend displays that the TaskManager connects?
>>> - As a hard core test: Can you bring up the jobmanager, check where it
>>> connects (10.216.192.98:6123 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.
>>>
>>> Thanks for helping us debug this, it is 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 <vidura...@icloud.com>
>>> wrote:
>>>
>>>> Hi,
>>>> 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
>>>>
>>>> bin/flink run <jar> doesn’t seem to work either. Let me send you my
>>>> command and the result 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/flink-0.9-SNAPSHOT/hamlet.txt
>>>> $FLINK_DIRECTORY/count
>>>>
>>>> 20:32:16,442 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 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.client.program.Client.run(Client.java:300)
>>>> at
>>>> org.apache.flink.client.program.ContextEnvironment.execute(ContextEnvironment.java:55)
>>>> at
>>>> org.apache.flink.examples.java.wordcount.WordCount.main(WordCount.java:82)
>>>> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
>>>> at
>>>> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
>>>> at
>>>> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
>>>> at java.lang.reflect.Method.invoke(Method.java:483)
>>>> at
>>>> org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:437)
>>>> at
>>>> org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:353)
>>>> at org.apache.flink.client.program.Client.run(Client.java:250)
>>>> at
>>>> org.apache.flink.client.CliFrontend.executeProgram(CliFrontend.java:371)
>>>> at org.apache.flink.client.CliFrontend.run(CliFrontend.java:344)
>>>> at
>>>> org.apache.flink.client.CliFrontend.parseParameters(CliFrontend.java:1087)
>>>> at org.apache.flink.client.CliFrontend.main(CliFrontend.java:1114)
>>>> Caused by: java.io.IOException: JobManager at akka.tcp://
>>>> flink@10.216.177.146:6123/user/jobmanager not reachable. Please make
>>>> sure that the JobManager is running and its port is reachable.
>>>> at
>>>> org.apache.flink.runtime.jobmanager.JobManager$.getJobManagerRemoteReference(JobManager.scala:897)
>>>> at
>>>> org.apache.flink.runtime.client.JobClient$.createJobClient(JobClient.scala:151)
>>>> at
>>>> org.apache.flink.runtime.client.JobClient$.createJobClientFromConfig(JobClient.scala:142)
>>>> at
>>>> org.apache.flink.runtime.client.JobClient$.startActorSystemAndActor(JobClient.scala:125)
>>>> at
>>>> org.apache.flink.runtime.client.JobClient.startActorSystemAndActor(JobClient.scala)
>>>> at org.apache.flink.client.program.Client.run(Client.java:322)
>>>> ... 15 more
>>>> Caused by: java.util.concurrent.TimeoutException: Futures timed out after
>>>> [10000 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
>>>> org.apache.flink.runtime.jobmanager.JobManager$.getJobManagerRemoteReference(JobManager.scala:893)
>>>> ... 20 more
>>>>
>>>> The exception above occurred while trying to run your command.
>>>>
>>>>
>>>>> On Feb 25, 2015, at 1:29 AM, Stephan Ewen <se...@apache.org> wrote:
>>>>>
>>>>> BTW: Does still work if you enter "localhost" for
>>>> "jobmanager.rpc.address"
>>>>> in your flink-conf.yaml ?
>>>>>
>>>>> On Tue, Feb 24, 2015 at 7:50 PM, Stephan Ewen <se...@apache.org> wrote:
>>>>>
>>>>>> Hi!
>>>>>>
>>>>>> I think that this is a problem in the current master (probably in there
>>>>>> since a few days ago). I am fixing it...
>>>>>>
>>>>>> Thanks for reporting it!
>>>>>>
>>>>>> Stephan
>>>>>>
>>>>>>
>>>>>> On Tue, Feb 24, 2015 at 6:52 PM, Stephan Ewen <se...@apache.org>
>>>> wrote:
>>>>>>
>>>>>>> Hi Dulaj!
>>>>>>>
>>>>>>> The log suggests that the JobManager binds itself to the IP
>>>>>>> address 10.216.192.98 and the WebClient runs at 127.0.0.1
>>>>>>>
>>>>>>> The 127.0.0.1 actor system cannot connect to the 10.216.192.98.
>>>>>>>
>>>>>>> Let me verify whether this is a quirk of your particular setup, or a
>>>> bug
>>>>>>> recently introduces in the 0.9-SNAPSHOT.
>>>>>>>
>>>>>>> Does the command line work for you? ("bin/flink run <jar>")
>>>>>>>
>>>>>>> taskmanager.numberOfTaskSlots: -1 is also okay, this will mean that
>>>> the
>>>>>>> default of '1' is used.
>>>>>>>
>>>>>>> Greetings,
>>>>>>> Stephan
>>>>>>>
>>>>>>>
>>>>>>>
>>>>>>> On Tue, Feb 24, 2015 at 5:18 PM, Dulaj Viduranga <
>>>> vidura...@icloud.com>
>>>>>>> wrote:
>>>>>>>
>>>>>>>> Is taskmanager.numberOfTaskSlots: -1 normal?
>>>>>>>>
>>>>>>>>> On Feb 24, 2015, at 9:44 PM, Robert Metzger <rmetz...@apache.org>
>>>>>>>> wrote:
>>>>>>>>>
>>>>>>>>> Hi,
>>>>>>>>> I could not find the logfiles attached to your mails. I think the
>>>>>>>>> mailinglists are not accepting attachments.
>>>>>>>>> Can you put the logs on gist.github.com?
>>>>>>>>>
>>>>>>>>> The configuration values are documented here:
>>>>>>>>> http://flink.apache.org/docs/0.8/config.html
>>>>>>>>> For the webclient's port its called webclient.port
>>>>>>>>>
>>>>>>>>> On Tue, Feb 24, 2015 at 5:04 PM, Dulaj Viduranga <
>>>> vidura...@icloud.com
>>>>>>>>>
>>>>>>>>> wrote:
>>>>>>>>>
>>>>>>>>>> I tried to kill the job manager manually in the terminal and start
>>>> it
>>>>>>>>>> again but no luck. Also could you tell me if it’s possible to
>>>> change
>>>>>>>>>> webclient’s port (8080) ?
>>>>>>>>>>
>>>>>>>>>>> On Feb 24, 2015, at 1:41 PM, Stephan Ewen <se...@apache.org>
>>>> wrote:
>>>>>>>>>>>
>>>>>>>>>>> Hey Dulaj!
>>>>>>>>>>>
>>>>>>>>>>> As a contributor, I would go against the latest version, which is
>>>>>>>>>>> 0.9-SNAPSHOT.
>>>>>>>>>>>
>>>>>>>>>>> It may be in your case that the JobManager actor is down, but the
>>>>>>>> process
>>>>>>>>>>> still lingers. (BTW: I have a patch pending that makes sure the
>>>>>>>> process
>>>>>>>>>>> disappears when the actor via down).
>>>>>>>>>>>
>>>>>>>>>>> Could you have a look at the log
>>>>>>>> "flink-<user>-jobmanager-<host>-.log"
>>>>>>>>>> and
>>>>>>>>>>> see if there are any errors logged?
>>>>>>>>>>>
>>>>>>>>>>> Greetings,
>>>>>>>>>>> Stephan
>>>>>>>>>>> Am 24.02.2015 06:29 schrieb "Dulaj Viduranga" <
>>>> vidura...@icloud.com
>>>>>>>>> :
>>>>>>>>>>>
>>>>>>>>>>>> The JobManager seems to run fine. I don't know. When I tried to
>>>> run
>>>>>>>>>>>> start-local.sh again, It shows the PID of the running JobManager
>>>> and
>>>>>>>>>> also
>>>>>>>>>>>> :8081 runs fine. I want to contribute to the project and I could
>>>>>>>> get a
>>>>>>>>>>>> little boost if I could see the capabilities of FLINK. :)
>>>>>>>>>>>> Will it be OK to use 0.8.1 as a developer?
>>>>>>>>>>>>
>>>>>>>>>>>> On Feb 24, 2015, at 04:15 AM, Stephan Ewen <se...@apache.org>
>>>>>>>> wrote:
>>>>>>>>>>>>
>>>>>>>>>>>> Hi Dulaj,
>>>>>>>>>>>>
>>>>>>>>>>>> That error message indicates that the JobManager is not running.
>>>>>>>> Are you
>>>>>>>>>>>> sure that the JobManager runs properly? Anything in the
>>>> JobManager
>>>>>>>> logs?
>>>>>>>>>>>>
>>>>>>>>>>>> BTW: The 0.9 branch is under heavy development / changes. That is
>>>>>>>> why it
>>>>>>>>>>>> may behave a bit different on different days right now. I would
>>>>>>>>>> recommend
>>>>>>>>>>>> to use the 0.8.1 release for a stable experience.
>>>>>>>>>>>>
>>>>>>>>>>>> Greetings,
>>>>>>>>>>>> Stephan
>>>>>>>>>>>>
>>>>>>>>>>>>
>>>>>>>>>>>> On Mon, Feb 23, 2015 at 7:39 PM, Robert Metzger <
>>>>>>>> rmetz...@apache.org>
>>>>>>>>>>>> wrote:
>>>>>>>>>>>>
>>>>>>>>>>>> Thank you for the quick reply.
>>>>>>>>>>>>
>>>>>>>>>>>> The log you've send is from the webclient. Can you also send the
>>>>>>>> log of
>>>>>>>>>> the
>>>>>>>>>>>>
>>>>>>>>>>>> JobManager?
>>>>>>>>>>>>
>>>>>>>>>>>> On Mon, Feb 23, 2015 at 7:28 PM, Dulaj Viduranga <
>>>>>>>> vidura...@icloud.com>
>>>>>>>>>>>>
>>>>>>>>>>>> wrote:
>>>>>>>>>>>>
>>>>>>>>>>>>> Yes. It seams it is not a problem with the arguments. I tried
>>>> two
>>>>>>>> days
>>>>>>>>>>>>
>>>>>>>>>>>> but
>>>>>>>>>>>>
>>>>>>>>>>>>> different error occurs. It seams the web client can’t connect to
>>>>>>>> the
>>>>>>>>>> job
>>>>>>>>>>>>
>>>>>>>>>>>>> manager although it is running
>>>>>>>>>>>>
>>>>>>>>>>>>> Right now, I can’t even get the webclient to run.
>>>>>>>>>>>>
>>>>>>>>>>>> ./bin/start-webclient.sh
>>>>>>>>>>>>
>>>>>>>>>>>>> executes fine but I cannot connect to localhost:8080 (even with
>>>>>>>> telnet
>>>>>>>>>> or
>>>>>>>>>>>>
>>>>>>>>>>>>> curl)
>>>>>>>>>>>>
>>>>>>>>>>>>> Here is the log for jobManager
>>>>>>>>>>>>
>>>>>>>>>>>>>
>>>>>>>>>>>>
>>>>>>>>>>>>> 23:22:31,933 INFO org.apache.flink.client.web.WebInterfaceServer
>>>>>>>>>>>>
>>>>>>>>>>>>> - Setting up web frontend server, using web-root directory
>>>>>>>>>>>>
>>>>>>>>>>>>>
>>>>>>>>>>>>
>>>>>>>>>>>> 'jar:
>>>>>>>>>>>>
>>>>>>>>>>
>>>>>>>>
>>>> file:/Users/Vidura/Documents/Development/flink/flink-dist/target/flink-0.9-SNAPSHOT-bin/flink-0.9-SNAPSHOT/lib/flink-clients-0.9-SNAPSHOT.jar!/web-docs
>>>>>>>>>>>> '.
>>>>>>>>>>>>
>>>>>>>>>>>>> 23:22:31,934 INFO org.apache.flink.client.web.WebInterfaceServer
>>>>>>>>>>>>
>>>>>>>>>>>>> - Web frontend server will store temporary files in
>>>>>>>>>>>>
>>>>>>>>>>>>> '/var/folders/3_/7gzbv7ks7q71lpm5d9hzrw2c0000gn/T', uploaded
>>>> jobs
>>>>>>>> in
>>>>>>>>>>>>
>>>>>>>>>>>>>
>>>> '/var/folders/3_/7gzbv7ks7q71lpm5d9hzrw2c0000gn/T/webclient-jobs',
>>>>>>>>>>>>
>>>>>>>>>>>>> plan-json-dumps in
>>>>>>>>>>>>
>>>>>>>>>>>>>
>>>> '/var/folders/3_/7gzbv7ks7q71lpm5d9hzrw2c0000gn/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.<init>(JobsInfoServlet.java:82)
>>>>>>>>>>>>
>>>>>>>>>>>>> at
>>>>>>>>>>>>
>>>>>>>>>>>>>
>>>>>>>>>>>>
>>>>>>>>>>>>
>>>>>>>>>>>>
>>>>>>>>>>
>>>>>>>>
>>>> org.apache.flink.client.web.WebInterfaceServer.<init>(WebInterfaceServer.java:158)
>>>>>>>>>>>>
>>>>>>>>>>>>> at org.apache.flink.client.WebFrontend.main(WebFrontend.java:74)
>>>>>>>>>>>>
>>>>>>>>>>>>>
>>>>>>>>>>>>
>>>>>>>>>>>>>
>>>>>>>>>>>>
>>>>>>>>>>>>>> On Feb 23, 2015, at 11:46 PM, Robert Metzger <
>>>> rmetz...@apache.org
>>>>>>>>>
>>>>>>>>>>>>
>>>>>>>>>>>>> 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
>>>>>>>>>>>>
>>>>>>>>>>>>>
>>>>>>>>>>>>
>>>>>>>>>>>>>
>>>>>>>>>>>>
>>>>>>>>>>>>
>>>>>>>>>>
>>>>>>>>>>
>>>>>>>>
>>>>>>>>
>>>>>>>
>>>>>>
>>>>
>>>>
>>>
>
