Details
-
Bug
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
None
Description
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
-
FLINK-34624 Enable local recovery in ChangelogRescalingITCase
- Closed
- links to