FLINK-11738

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-11738

/**
     * 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;
    }

---

1.7.2後flink修復調整

/**
     * 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;
    }

mail-archives

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