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

AutoRescalingITCase#testCheckpointRescalingInKeyedState AssertionError

    XMLWordPrintableJSON

Details

    Description

      https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=58249&view=ms.vss-test-web.build-test-results-tab&runId=4036370&resultId=100718&paneView=debug

       

      expected:<[(0,8000), (0,32000), (0,48000), (0,72000), (1,78000), (1,30000), (1,54000), (0,2000), (0,10000), (0,50000), (0,66000), (0,74000), (0,82000), (1,80000), (1,0), (1,16000), (1,24000), (1,40000), (1,56000), (1,64000), (0,12000), (0,28000), (0,52000), (0,60000), (0,68000), (0,76000), (1,18000), (1,26000), (1,34000), (1,42000), (1,58000), (0,6000), (0,14000), (0,22000), (0,38000), (0,46000), (0,62000), (0,70000), (1,4000), (1,20000), (1,36000), (1,44000)]> but was:<[(0,8000), (0,32000), (0,48000), (0,72000), (1,78000), (1,30000), (1,54000), (0,2000), (0,10000), (0,50000), (0,66000), (0,74000), (0,82000), (0,23000), (0,31000), (1,80000), (1,0), (1,16000), (1,24000), (1,40000), (1,56000), (1,64000), (0,12000), (0,28000), (0,52000), (0,60000), (0,68000), (0,76000), (1,18000), (1,26000), (1,34000), (1,42000), (1,58000), (0,6000), (0,14000), (0,22000), (0,19000), (0,35000), (1,4000), (1,20000), (1,36000), (1,44000)]>

       

      This maybe related to FLINK-34624 as we could see from the log:

      03:31:02,073 [ main] INFO org.apache.flink.runtime.testutils.PseudoRandomValueSelector [] - Randomly selected true for state.changelog.enabled
03:31:02,163 [jobmanager-io-thread-2] INFO org.apache.flink.state.changelog.AbstractChangelogStateBackend [] - ChangelogStateBackend is used, delegating EmbeddedRocksDBStateBackend.

      FLINK-34624 disables changelog since it doesn't support local rescaling currently.

      Even if disabling changelog for AutoRescalingITCase manually, 
      randomization may still be applied to it.
      We should apply randomization only when it's not pre-defined.
       

       

       

      Attachments

        Issue Links

          is related to

          Technical Debt - FLINK-34624 Enable local recovery in ChangelogRescalingITCase

          • Major - Major loss of function.
          • Closed
          links to

          Web Link GitHub Pull Request #24488

          Web Link GitHub Pull Request #24504

          Activity

            People

              masteryhx Hangxiang Yu
              masteryhx Hangxiang Yu
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: