This is an automated email from the ASF dual-hosted git repository. tzulitai pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink-statefun.git
commit 80aa4ae94ca74d83c36b383ab1d7342a48a96c12 Author: Igal Shilman <igalshil...@gmail.com> AuthorDate: Thu Sep 10 12:30:20 2020 +0200 [FLINK-19191] Set the default maxInflightAsyncOperations to 1024 The default upper limit for async operations per task slot is currently set to 10 million, and it is unrealistically high, we set it to a more realistic value. A closer example would be the recommend value in Flink's AsyncWait operator. This closes #145. --- .../org/apache/flink/statefun/flink/core/StatefulFunctionsConfig.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/StatefulFunctionsConfig.java b/statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/StatefulFunctionsConfig.java index 358384d..ae338f3 100644 --- a/statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/StatefulFunctionsConfig.java +++ b/statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/StatefulFunctionsConfig.java @@ -90,7 +90,7 @@ public class StatefulFunctionsConfig implements Serializable { public static final ConfigOption<Integer> ASYNC_MAX_OPERATIONS_PER_TASK = ConfigOptions.key("statefun.async.max-per-task") .intType() - .defaultValue(10_000_000) + .defaultValue(1024) .withDescription( "The max number of async operations per task before backpressure is applied.");