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
>> >>>>
>> >>>>>
>> >>>>
>> >>>>>
>> >>>>
>> >>>>
>> >>
>> >>
>>
>>
>
