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

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

              Dates

                Created:
                Updated:
                Resolved: