You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tz...@apache.org on 2020/09/21 08:33:03 UTC
[flink] 03/03: [FLINK-18661] [kinesis] Updated FullJitterBackoff
Default values for describeStream and describeStreamConsumer
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.git
commit 17f1af220c2849e7ab2e7e004ce411b761c8966c
Author: Hong Teoh <li...@amazon.com>
AuthorDate: Mon Sep 14 22:48:10 2020 +0100
[FLINK-18661] [kinesis] Updated FullJitterBackoff Default values for describeStream and describeStreamConsumer
This closes #13189.
---
.../connectors/kinesis/config/ConsumerConfigConstants.java | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
diff --git a/flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config/ConsumerConfigConstants.java b/flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config/ConsumerConfigConstants.java
index 00da231..5c9f62c 100644
--- a/flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config/ConsumerConfigConstants.java
+++ b/flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config/ConsumerConfigConstants.java
@@ -242,9 +242,9 @@ public class ConsumerConfigConstants extends AWSConfigConstants {
public static final String DEFAULT_STREAM_TIMESTAMP_DATE_FORMAT = "yyyy-MM-dd'T'HH:mm:ss.SSSXXX";
- public static final int DEFAULT_STREAM_DESCRIBE_RETRIES = 10;
+ public static final int DEFAULT_STREAM_DESCRIBE_RETRIES = 50;
- public static final long DEFAULT_STREAM_DESCRIBE_BACKOFF_BASE = 1000L;
+ public static final long DEFAULT_STREAM_DESCRIBE_BACKOFF_BASE = 2000L;
public static final long DEFAULT_STREAM_DESCRIBE_BACKOFF_MAX = 5000L;
@@ -258,11 +258,11 @@ public class ConsumerConfigConstants extends AWSConfigConstants {
public static final int DEFAULT_LIST_SHARDS_RETRIES = 10;
- public static final int DEFAULT_DESCRIBE_STREAM_CONSUMER_RETRIES = 10;
+ public static final int DEFAULT_DESCRIBE_STREAM_CONSUMER_RETRIES = 50;
- public static final long DEFAULT_DESCRIBE_STREAM_CONSUMER_BACKOFF_BASE = 200L;
+ public static final long DEFAULT_DESCRIBE_STREAM_CONSUMER_BACKOFF_BASE = 2000L;
- public static final long DEFAULT_DESCRIBE_STREAM_CONSUMER_BACKOFF_MAX = 1000L;
+ public static final long DEFAULT_DESCRIBE_STREAM_CONSUMER_BACKOFF_MAX = 5000L;
public static final double DEFAULT_DESCRIBE_STREAM_CONSUMER_BACKOFF_EXPONENTIAL_CONSTANT = 1.5;