Details
-
Bug
-
Status: Resolved
-
Critical
-
Resolution: Fixed
-
1.12.2
Description
kinesis `SHARD_GETRECORDS_INTERVAL_MILLIS`
mean between normal getRecords sleep.
But at end . The value was used in exception.
// sleep for the fetch interval before the next getRecords attempt with the // refreshed iterator if (expiredIteratorBackoffMillis != 0) { Thread.sleep(expiredIteratorBackoffMillis); }
return new PollingRecordPublisher( startingPosition, streamShardHandle, metricsReporter, kinesisProxy, configuration.getMaxNumberOfRecordsPerFetch(), configuration.getFetchIntervalMillis());
But the last arg was expiredIteratorBackoffMillis.
Is this a problem?
Attachments
Issue Links
- is caused by
-
FLINK-18512 [Kinesis][EFO] Introduce RecordPublisher Interface
- Resolved
- links to