flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rmetzger <...@git.apache.org>
Subject [GitHub] flink pull request #2131: [FLINK-3231][streaming-connectors] FlinkKinesisCon...
Date Fri, 01 Jul 2016 09:39:13 GMT
Github user rmetzger commented on a diff in the pull request:

    https://github.com/apache/flink/pull/2131#discussion_r69274234
  
    --- Diff: flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config/KinesisConfigConstants.java
---
    @@ -68,10 +97,30 @@
     	//  Default configuration values
     	// ------------------------------------------------------------------------
     
    -	public static final int DEFAULT_STREAM_DESCRIBE_RETRY_TIMES = 3;
    +	public static final long DEFAULT_STREAM_DESCRIBE_BACKOFF_BASE = 1000L;
    +
    +	public static final long DEFAULT_STREAM_DESCRIBE_BACKOFF_MAX = 5000L;
    +
    +	public static final double DEFAULT_STREAM_DESCRIBE_BACKOFF_EXPONENTIAL_CONSTANT = 1.5;
    +
    +	public static final int DEFAULT_SHARD_GETRECORDS_MAX = 100;
    +
    +	public static final int DEFAULT_SHARD_GETRECORDS_RETRIES = 3;
    +
    +	public static final long DEFAULT_SHARD_GETRECORDS_BACKOFF_BASE = 300L;
    +
    +	public static final long DEFAULT_SHARD_GETRECORDS_BACKOFF_MAX = 1000L;
    +
    +	public static final double DEFAULT_SHARD_GETRECORDS_BACKOFF_EXPONENTIAL_CONSTANT = 1.5;
    +
    +	public static final int DEFAULT_SHARD_GETITERATOR_RETRIES = 3;
    +
    +	public static final long DEFAULT_SHARD_GETITERATOR_BACKOFF_BASE = 300L;
    +
    +	public static final long DEFAULT_SHARD_GETITERATOR_BACKOFF_MAX = 1000L;
     
    -	public static final long DEFAULT_STREAM_DESCRIBE_BACKOFF = 1000L;
    +	public static final double DEFAULT_SHARD_GETITERATOR_BACKOFF_EXPONENTIAL_CONSTANT =
1.5;
     
    -	public static final int DEFAULT_SHARD_RECORDS_PER_GET = 100;
    +	public static final long DEFAULT_SHARD_DISCOVERY_INTERVAL_MILLIS = 10000L;
    --- End diff --
    
    Okay. 10 seconds is okay as well.



---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

Mime
View raw message