Re: JobManager is no longer reachable

2015-07-21 Thread Stephan Ewen
t;>>>>>> >>>>>>> >>>>>>> Greetings, >>>>>>> Stephan >>>>>>> >>>>>>> >>>>>>> On Mon, Jun 29, 2015 at 12:39 PM, Stephan Ewen >>>>>>> wrote:

Re: JobManager is no longer reachable

2015-07-21 Thread Flavio Pompermaier
On Mon, Jun 29, 2015 at 12:39 PM, Stephan Ewen >>>>>> wrote: >>>>>> >>>>>>> Hi Flavio! >>>>>>> >>>>>>> Can you post the JobManager's log here? It should have the message >

Re: JobManager is no longer reachable

2015-07-21 Thread Stephan Ewen
er's log here? It should have the message >>>>>> about what is going wrong... >>>>>> >>>>>> Stephan >>>>>> >>>>>> >>>>>> On Mon, Jun 29, 2015 at 11:43 AM, Fla

Re: JobManager is no longer reachable

2015-07-21 Thread Flavio Pompermaier
gt;> >>>>> >>>>> On Mon, Jun 29, 2015 at 11:43 AM, Flavio Pompermaier < >>>>> pomperma...@okkam.it> wrote: >>>>> >>>>>> Hi to all, >>>>>> >>>>>> I'm restarting the discussion about a p

Re: JobManager is no longer reachable

2015-07-21 Thread Stephan Ewen
started with a different subject). >>>>> I'm running Flink 0.9.0 on CDH 5.1.3 so I compiled the sources as: >>>>> >>>>> mvn clean install -Dhadoop.version=2.3.0-cdh5.1.3 >>>>> -Dhbase.version=0.98.1-cdh5.1.3 -Dhadoop.core.versio

Re: JobManager is no longer reachable

2015-06-29 Thread Flavio Pompermaier
.1-cdh5.1.3 -Dhadoop.core.version=2.3.0-mr1-cdh5.1.3 >>>> -DskipTests -Pvendor-repos >>>> >>>> The problem I'm facing is that the cluster start successfully but when >>>> I run my job (from the web-client) I get, after some time,

Re: JobManager is no longer reachable

2015-06-29 Thread Flavio Pompermaier
#x27;m facing is that the cluster start successfully but when I >>> run my job (from the web-client) I get, after some time, this exception: >>> >>> 16:35:41,636 WARN akka.remote.RemoteWatcher >>> - Detected unreachable: [akka.tcp://flink@192.168.234.83:6123] >>> 16:35:46,6

Re: JobManager is no longer reachable

2015-06-29 Thread Stephan Ewen
luster start successfully but when I >> run my job (from the web-client) I get, after some time, this exception: >> >> 16:35:41,636 WARN akka.remote.RemoteWatcher >> - Detected unreachable: [akka.tcp://flink@192.168.234.83:6123] >> 16:35:

Re: JobManager is no longer reachable

2015-06-29 Thread Stephan Ewen
hable: [akka.tcp://flink@192.168.234.83:6123] > 16:35:46,605 INFO org.apache.flink.runtime.taskmanager.TaskManager - > Disconnecting from JobManager: JobManager is no longer reachable > 16:35:46,614 INFO org.apache.flink.runtime.taskmanager.TaskManager - > Cancelling all computations and discarding all cached data. > 16:35

JobManager is no longer reachable

2015-06-29 Thread Flavio Pompermaier
able: [akka.tcp://flink@192.168.234.83:6123] 16:35:46,605 INFO org.apache.flink.runtime.taskmanager.TaskManager - Disconnecting from JobManager: JobManager is no longer reachable 16:35:46,614 INFO org.apache.flink.runtime.taskmanager.TaskManager - Cancelling all computations and discarding all cac