[flink-statefun] 02/03: [FLINK-19191] Set the default maxInflightAsyncOperations to 1024

[tz...@apache.org]

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 <ig...@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.");