Github user kailashhd commented on a diff in the pull request:
https://github.com/apache/flink/pull/5992#discussion_r188377363
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config/ConsumerConfigConstants.java
---
@@ -65,14 +65,14 @@ public SentinelSequenceNumber
toSentinelSequenceNumber() {
/** The date format of initial timestamp to start reading Kinesis
stream from (when AT_TIMESTAMP is set for STREAM_INITIAL_POSITION). */
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 --
For the time being, I will keep the older names and make the changes to
deprecate the property names in the followup PR. I am not sure what the policy
is with respect to changes size. I feel breaking this up to 2 different PRs
will make it easier to review. Let me know if you feel otherwise. I will pull
in those changes into this PR then.
---
