t;>>>>>>
>>>>>>>
>>>>>>> Greetings,
>>>>>>> Stephan
>>>>>>>
>>>>>>>
>>>>>>> On Mon, Jun 29, 2015 at 12:39 PM, Stephan Ewen
>>>>>>> wrote:
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
>
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
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
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
.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,
#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
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:
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
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
10 matches
Mail list logo