|
Rename Variable attemptCount : int to retryCount : int in method private listShards(streamName String, startShardId String, startNextToken String) : ListShardsResult in class org.apache.flink.streaming.connectors.kinesis.proxy.KinesisProxy |
From |
To |
|
Rename Variable attempt : int to retryCount : int in method private getShardIterator(getShardIteratorRequest GetShardIteratorRequest) : String in class org.apache.flink.streaming.connectors.kinesis.proxy.KinesisProxy |
From |
To |
|
Rename Variable attempt : int to retryCount : int in method public getRecords(shardIterator String, maxRecordsToGet int) : GetRecordsResult in class org.apache.flink.streaming.connectors.kinesis.proxy.KinesisProxy |
From |
To |