Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-21661

SHARD_GETRECORDS_INTERVAL_MILLIS wrong use?

    XMLWordPrintableJSON

    Details

      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

            Activity

              People

              • Assignee:
                dannycranmer Danny Cranmer
                Reporter:
                jiamo jiamo
              • Votes:
                0 Vote for this issue
                Watchers:
                2 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: