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

巴特西

FLINK-11738

1.7.2后flink修复调整

最新文章

热门文章