flink
flink copied to clipboard
[FLINK-31238] [WIP] Use IngestDB to speed up Rocksdb rescaling recovery (rebased)
Rebased and slightly refactored version of #23169.
CI report:
- 6d68d32d70fa445cb8e042d7ab14ca46c9496271 Azure: FAILURE
- 05a7a0d9948c4f4e2502b69db9b4cdfcd2070aab Azure: PENDING
Bot commands
The @flinkbot bot supports the following commands:-
@flinkbot run azure
re-run the last Azure build
@rkhachatryan Can you take one more look? I have fixed all problems that I encountered in the original PR and also addressed your comments. Using TestStreamEnvironment.randomizeConfiguration
seems a bit problematic because the RocksDB config keys are not visible in that module. We also still need to change to frocksDB version and the notice file once we have the release.
One more thing, we should probably update the UI and show the new flag under Checkpoints / Configuration
. But that can be a separate PR.