flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From glaksh100 <...@git.apache.org>
Subject [GitHub] flink pull request #6300: [FLINK-9692][Kinesis Connector] Adaptive reads fro...
Date Fri, 13 Jul 2018 02:13:50 GMT
Github user glaksh100 commented on a diff in the pull request:

    https://github.com/apache/flink/pull/6300#discussion_r202227834
  
    --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config/ConsumerConfigConstants.java
---
    @@ -134,6 +134,10 @@ public SentinelSequenceNumber toSentinelSequenceNumber() {
     	/** The interval between each attempt to discover new shards. */
     	public static final String SHARD_DISCOVERY_INTERVAL_MILLIS = "flink.shard.discovery.intervalmillis";
     
    +	/** The config to turn on adaptive reads from a shard. */
    +	public static final String SHARD_USE_ADAPTIVE_READS = "flink.shard.use.adaptive.reads";
    --- End diff --
    
    Changed.


---

Mime
View raw message