You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "jiamo (Jira)" <ji...@apache.org> on 2021/03/08 09:33:00 UTC

[jira] [Created] (FLINK-21661) SHARD_GETRECORDS_INTERVAL_MILLIS wrong use?

jiamo created FLINK-21661:
-----------------------------

             Summary: SHARD_GETRECORDS_INTERVAL_MILLIS  wrong use?
                 Key: FLINK-21661
                 URL: https://issues.apache.org/jira/browse/FLINK-21661
             Project: Flink
          Issue Type: Bug
          Components: Connectors / Kinesis
    Affects Versions: 1.12.1
            Reporter: jiamo


kinesis `SHARD_GETRECORDS_INTERVAL_MILLIS`

mean between normal getRecords sleep.

But at end . The value was used in exception.
{code:java}
 
// sleep for the fetch interval before the next getRecords attempt with the
// refreshed iterator
if (expiredIteratorBackoffMillis != 0) {
 Thread.sleep(expiredIteratorBackoffMillis);
}
{code}
Is this a problem?

 

 

 

 

 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)