flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kailashhd <...@git.apache.org>
Subject [GitHub] flink pull request #5992: [FLINK-8944] [Kinesis Connector] Use listShards in...
Date Fri, 11 May 2018 14:32:59 GMT
Github user kailashhd commented on a diff in the pull request:

    https://github.com/apache/flink/pull/5992#discussion_r187632455
  
    --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config/ConsumerConfigConstants.java
---
    @@ -66,13 +66,13 @@ public SentinelSequenceNumber toSentinelSequenceNumber() {
     	public static final String STREAM_TIMESTAMP_DATE_FORMAT = "flink.stream.initpos.timestamp.format";
     
     	/** The base backoff time between each describeStream attempt. */
    -	public static final String STREAM_DESCRIBE_BACKOFF_BASE = "flink.stream.describe.backoff.base";
    --- End diff --
    
    I have retained the properties string values as same but changed the variable names to
indicate listShards for readability. 


---

Mime
View raw message