thinktothings created FLINK-11738:
-------------------------------------
Summary: 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
Key: FLINK-11738
URL:
https://issues.apache.org/jira/browse/FLINK-11738 Project: Flink
Issue Type: Bug
Components: Client
Affects Versions: 1.7.2
Environment: flink 1.7.2 client
!image-2019-02-25-10-57-20-106.png!
!image-2019-02-25-10-57-32-876.png!
!image-2019-02-25-10-57-39-753.png!
Reporter: thinktothings
Attachments: image-2019-02-25-10-57-20-106.png, image-2019-02-25-10-57-32-876.png, image-2019-02-25-10-57-39-753.png
Akka.ask.timeout 10 seconds, this miniCluster environment is written dead, can not be changed?
---------------------------------------------------------------------------------------------------------------------------------
public class ConfigOptions {
/**
* Starts building a new \{@link ConfigOption}.
*
* @param key The key for the config option.
* @return The builder for the config option with the given key.
*/
public static OptionBuilder key(String key) {
checkNotNull(key);
return new OptionBuilder(key);
}
---------------------------------------------------------------------------------------------------------------------------------
public class AkkaOptions {
/**
* Timeout for akka ask calls.
*/
public static final ConfigOption<String> ASK_TIMEOUT = ConfigOptions
.key("akka.ask.timeout")
.defaultValue("10 s")
.withDescription("Timeout used for all futures and blocking Akka calls. If Flink fails due to timeouts then you" +
" should try to increase this value. Timeouts can be caused by slow machines or a congested network. The" +
" timeout value requires a time-unit specifier (ms/s/min/h/d).");
---------------------------------------------------------------------------------------------------------------------------------
---------------------------------------------------------------------------------------------------------------------------------
---------------------------------------------------------------------------------------------------------------------------------
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
Locked
