Calling:
java -cp ../examples/flink-java-examples-0.9-SNAPSHOT-KMeans.jar
org.apache.flink.examples.java.clustering.util.KMeansDataGenerator 500 10
0.08
Will not connect to Flink. Its just running a standalone KMeans data
generator, not KMeans.
I would suspect that the KMeans example is not running as well.
You can run the KMeans example like this:
bin/flink run ./examples/flink-java-examples-0.9-SNAPSHOT-KMeans.jar.
On Sat, Feb 28, 2015 at 5:47 AM, Dulaj Viduranga <vidura...@icloud.com>
wrote:
> 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
> >>>>>>>>>>>>
> >>>>>>>>>>>>>
> >>>>>>>>>>>>
> >>>>>>>>>>>>>
> >>>>>>>>>>>>
> >>>>>>>>>>>>
> >>>>>>>>>>
> >>>>>>>>>>
> >>>>>>>>
> >>>>>>>>
> >>>>>>>
> >>>>>>
> >>>>
> >>>>
> >>>
> >
>
>
