Re: org.apache.flink.runtime.rpc.exceptions.FencingTokenException:

2018-10-15 Thread Till Rohrmann
gt; > 2018-10-13 03:02:01,337 ERROR > org.apache.flink.runtime.rest.handler.taskmanager.TaskManagersHandler - > Could not retrieve the redirect address. > > java.util.concurrent.CompletionException: > org.apache.flink.runtime.rpc.exceptions.FencingTokenException: Fencing > token not set: Ignoring message > LocalFencedMessage(8b79d4540b45b3

RE: org.apache.flink.runtime.rpc.exceptions.FencingTokenException:

2018-10-12 Thread Samir Tusharbhai Chauhan
: org.apache.flink.runtime.rpc.exceptions.FencingTokenException: Fencing token not set: Ignoring message LocalFencedMessage(8b79d4540b45b3e622748b813d3a464b, LocalRpcInvocation(requestRestAddress(Time))) sent to akka.tcp://flink@127.0.0.1:50010/user/dispatcher because the fencing token is null. Warm Regards, Samir Chauhan From: Till

Re: org.apache.flink.runtime.rpc.exceptions.FencingTokenException:

2018-10-06 Thread Till Rohrmann
Chauhan > > > > *From:* Till Rohrmann [mailto:trohrm...@apache.org] > *Sent:* Friday, October 05, 2018 11:09 PM > *To:* Samir Tusharbhai Chauhan > > *Cc:* user > *Subject:* Re: > org.apache.flink.runtime.rpc.exceptions.FencingTokenException: > > > > Hi Samir

RE: org.apache.flink.runtime.rpc.exceptions.FencingTokenException:

2018-10-06 Thread Samir Tusharbhai Chauhan
: org.apache.flink.runtime.rpc.exceptions.FencingTokenException: Hi Samir, could you share the logs of the two JMs and the log where you saw the FencingTokenException with us? It looks to me as if the TM had an outdated fencing token (an outdated leader session id) with which it contacted the ResourceManager. This can

Re: org.apache.flink.runtime.rpc.exceptions.FencingTokenException:

2018-10-05 Thread Till Rohrmann
> > > > > > *From:* Till Rohrmann [mailto:trohrm...@apache.org] > *Sent:* Friday, October 05, 2018 11:09 PM > *To:* Samir Tusharbhai Chauhan > > *Cc:* user > *Subject:* Re: > org.apache.flink.runtime.rpc.exceptions.FencingTokenException: > > > > Hi S

RE: org.apache.flink.runtime.rpc.exceptions.FencingTokenException:

2018-10-05 Thread Samir Tusharbhai Chauhan
Chauhan Cc: user Subject: Re: org.apache.flink.runtime.rpc.exceptions.FencingTokenException: Hi Samir, could you share the logs of the two JMs and the log where you saw the FencingTokenException with us? It looks to me as if the TM had an outdated fencing token (an outdated leader session id

Re: org.apache.flink.runtime.rpc.exceptions.FencingTokenException:

2018-10-05 Thread Till Rohrmann
t; > state.savepoints.dir: file:///sharedflink/state_dir/savepoint > > state.backend.incremental: false > > state.backend.rocksdb.timer-service.factory: rocksdb > > state.backend.local-recovery: false > > > > But when I start services, I get this error mess

org.apache.flink.runtime.rpc.exceptions.FencingTokenException:

2018-10-05 Thread Samir Tusharbhai Chauhan
But when I start services, I get this error message. java.util.concurrent.CompletionException: org.apache.flink.runtime.rpc.exceptions.FencingTokenException: Fencing token mismatch: Ignoring message RemoteFencedMessage(b00185a18ea3da17ebe39ac411a84f3a, RemoteRpcInvocation