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

All records are processed in the close stage in ContinuousFileReaderOperatorBenchmark

    XMLWordPrintableJSON

Details

    Description

      The TARGET_COUNT_REACHED_LATCH is not correctly reset after the warmup iterations and thus subsequent runs process all records in the CLOSE stage of the ContinuousFileReaderOperator testing something different than anticipated.

      Attachments

        Issue Links

          Activity

            People

              dwysakowicz Dawid Wysakowicz
              dwysakowicz Dawid Wysakowicz
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: