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]]
after [10000 ms]. Sender[null] sent message of type
"org.apache.flink.runtime.rpc.messages.LocalFencedMessage".
Best regards,
Alex soto
> On Apr 12, 2019, at 6:34 PM, Abdul Qadeer <[email protected]> wrote:
>
> Hi Alex,
>
> The timeout shown in the exception is due to AkkaOptions.LOOKUP_TIMEOUT
>
> On Fri, 12 Apr 2019 at 09:45, Alex Soto <[email protected]
> <mailto:[email protected]>> 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.ASK_TIMEOUT, "2 min");
> cfg.setString(AkkaOptions.CLIENT_TIMEOUT, "2 min");
>
> LocalEnvironment env =
> ExecutionEnvironment.createLocalEnvironment(cfg);
>
> Yet, when I run the test, I am getting the following error:
>
> Caused by: akka.pattern.AskTimeoutException: Ask timed out on
> [Actor[akka://flink/user/dispatcher87b320bd-c3c8-485f-82f7-113f52fb46a1#-1843625489
> <>]] after [10000 ms]. Sender[null] sent message of type
> "org.apache.flink.runtime.rpc.messages.LocalFencedMessage".
> at akka.pattern.PromiseActorRef$.$anonfun$apply$1(AskSupport.scala:604)
> at akka.actor.Scheduler$$anon$4.run(Scheduler.scala:126)
> at
> scala.concurrent.Future$InternalCallbackExecutor$.unbatchedExecute(Future.scala:870)
> at scala.concurrent.BatchingExecutor.execute(BatchingExecutor.scala:109)
> at
> scala.concurrent.BatchingExecutor.execute$(BatchingExecutor.scala:103)
> at
> scala.concurrent.Future$InternalCallbackExecutor$.execute(Future.scala:868)
> at
> akka.actor.LightArrayRevolverScheduler$TaskHolder.executeTask(LightArrayRevolverScheduler.scala:329)
> at
> akka.actor.LightArrayRevolverScheduler$$anon$4.executeBucket$1(LightArrayRevolverScheduler.scala:280)
> at
> akka.actor.LightArrayRevolverScheduler$$anon$4.nextTick(LightArrayRevolverScheduler.scala:284)
> at
> akka.actor.LightArrayRevolverScheduler$$anon$4.run(LightArrayRevolverScheduler.scala:236)
> at java.lang.Thread.run(Thread.java:748)
>
>
>
> The question is why doesn’t Flink honor the timeout configuration values I am
> passing when creating the local environment. I am passing 2 minutes, bu the
> error message says it timed out after 10 seconds.
>
>
> Best regards,
> Alex soto
>
>
>
>
