caused by: akka.pattern.asktimeoutexception: ask timed out on flink
Caused by: akka.pattern.AskTimeoutException: Ask timed out on [Actor[akka://flink/user/dispatcher15e85f5d-a55d-4773-8197-f0db5658f55b#1335897563]] after [10000 ms]. Sender[null] sent
FLINK-11738java
/** * Creates a new Flink mini cluster based on the given configuration. * * @param miniClusterConfiguration The configuration for the mini cluster */ public MiniCluster(MiniClusterConfiguration miniClusterConfiguration) { this.miniClusterConfiguration = checkNotNull(miniClusterConfiguration, "config may not be null"); this.rpcTimeout = Time.seconds(10L); this.terminationFuture = CompletableFuture.completedFuture(null); running = false; }
/** * Creates a new Flink mini cluster based on the given configuration. * * @param miniClusterConfiguration The configuration for the mini cluster */ public MiniCluster(MiniClusterConfiguration miniClusterConfiguration) { this.miniClusterConfiguration = checkNotNull(miniClusterConfiguration, "config may not be null"); this.rpcTimeout = miniClusterConfiguration.getRpcTimeout(); this.terminationFuture = CompletableFuture.completedFuture(null); running = false; }
akka.ask.timeout: 60 s <yD> env.java.opts="-Djava.util.Arrays.useLegacyMergeSort=true"</yD> -yD web.timeout="1000000" <yD> akka.ask.timeout="1 d"</yD> -yD akka.ask.timeout="1 d"
Hello, does anybody have an idea what is going on? I have not yet found a solution. Am I doing something wrong? Or is the 'akka.ask.timeout' parameter not related to the exception stated below? Could somebody please take a look at this? More details can be found in the message prior to this. akka.pattern.AskTimeoutException: Ask timed out on [Actor[akka://flink/user/dispatcher8df05371-effc-468b-8a22-e2f364f65d6a#582308583]] after [10000 ms] Best regards, Lukas