user/resourcemanager#-1602864959]] after [1 ms].
Message of type [org.apache.flink.runtime.rpc.messages.LocalFencedMessage]. A
typical reason for `AskTimeoutException` is that the recipient actor didn't
send a reply.at
akka.pattern.PromiseActorRef$$anonfun$2.apply(As
ausing the flink jobs to
> die.
>
> Caused by: akka.pattern.AskTimeoutException: Ask timed out on
> [Actor[akka://flink/user/resourcemanager#-1602864959]] after [1 ms].
> Message of type [org.apache.flink.runtime.rpc.messages.LocalFencedMessage].
> A typical reason for `AskTime
ical reason for `AskTimeoutException` is that the recipient actor didn't
send a reply.at
akka.pattern.PromiseActorRef$$anonfun$2.apply(AskSupport.scala:635)at
akka.pattern.PromiseActorRef$$anonfun$2.apply(AskSupport.scala:635)at
akka.pattern.PromiseActorRef$$anonfun$1.apply$mcV$sp(
s.LocalFencedMessage].
> A typical reason for `AskTimeoutException` is that the recipient actor
> didn't send a reply.
> at akka.pattern.PromiseActorRef$$anonfun$2.apply(AskSupport.scala:635)
> at akka.pattern.PromiseActorRef$$anonfun$2.apply(AskSupport.scala:635)
> at
> akka.
[org.apache.flink.runtime.rpc.messages.LocalFencedMessage]. A
typical reason for `AskTimeoutException` is that the recipient actor didn't
send a reply.at
akka.pattern.PromiseActorRef$$anonfun$2.apply(AskSupport.scala:635)at
akka.pattern.PromiseActorRef$$anonfun$2.apply(AskSupport.scala:635)
I found the issue was a hard-coded timeout value in MiniCluster class, which is
used for stand alone execution:
public MiniCluster(MiniClusterConfiguration miniClusterConfiguration) {
this.miniClusterConfiguration =
checkNotNull(miniClusterConfiguration, "config may not
Thanks Abdul for the help. So I added this:
cfg.setString(AkkaOptions.LOOKUP_TIMEOUT, "2 min");
But I am still I am getting the same error:
Caused by: akka.pattern.AskTimeoutException: Ask timed out on
[Actor[akka://flink/user/dispatcher62bab021-4a79-4d10-8d45-7a33c493a925#-199361569]
Hi Alex,
The timeout shown in the exception is due to AkkaOptions.LOOKUP_TIMEOUT
On Fri, 12 Apr 2019 at 09:45, Alex Soto wrote:
> Hello,
>
> I am using Flink version 1.7.1. In a unit test, I create a local
> environment:
>
> Configuration cfg = new Configuration();
> cfg.setString(AkkaOptions.
Hello,
I am using Flink version 1.7.1. In a unit test, I create a local environment:
Configuration cfg = new Configuration();
cfg.setString(AkkaOptions.ASK_TIMEOUT, "2 min");
cfg.setString(AkkaOptions.CLIENT_TIMEOUT, "2 min");
Local
019 at 11:03 PM
Subject: AskTimeoutException - Cannot deploy task
To: user
Hi,
I see the following exceptions, will really appreciate any help on that
Thanks
Avi
This is the first one (out of three) :
java.lang.Exception: Cannot deploy task KeyedProcess -> Sink: Unnamed
Hi,
I see the following exceptions, will really appreciate any help on that
Thanks
Avi
This is the first one (out of three) :
java.lang.Exception: Cannot deploy task KeyedProcess -> Sink: Unnamed
(3/100) (2c9646634afe1488659da404e92697b0) - TaskManager
(container_e03_1553795623823_0001_01_000
flink 1.4.2 we set *akka.client.timeout* to a high value to make sure
>> the request did not timeout
>>
>> However on flink 1.6.0 I get an *AskTimeoutException* and increasing
>> *akka.client.timeout* only works if i apply it to the running flink
>> process.
>> Ap
; the request did not timeout
>
> However on flink 1.6.0 I get an *AskTimeoutException* and increasing
> *akka.client.timeout* only works if i apply it to the running flink
> process.
> Applying it to just the flink client does nothing.
>
> I am reluctant to configure this on
set *akka.client.timeout* to a high value to make sure
the request did not timeout
However on flink 1.6.0 I get an *AskTimeoutException* and increasing
*akka.client.timeout* only works if i apply it to the running flink process.
Applying it to just the flink client does nothing.
I am reluctant
14 matches
Mail list logo
