Roman

[WIP][FLINK-26372][runtime][state] Allow to configure Changelog Storage per program

1

``` Because different changelog implementations might have different options, the configuration is passed as a (serialized) string map. To extract the relevant KV-pairs (and not pass the whole configuration), Changelog...

[FLINK-29158] Fix logging in DefaultCompletedCheckpointStore

3

## What is the purpose of the change Fix swapped log messages on checkpoint subsumption. ## Verifying this change This change is a trivial rework without any test coverage. ##...

[FLINK-34417] Log Job ID via MDC

5

## What is the purpose of the change Add Flink JobID to logging MDC to make analysing the logs easier. ## Verifying this change - added `JobIdLoggingMainThreadExecutor` - tested manually...

[FLINK-31261][runtime] Make AdaptiveScheduler aware of local state size

1

## What is the purpose of the change FLINK-21450 / #21981 made Adaptive Scheduler aware of Local State. This PR improves on that by estimating state size (instead of number...

[FLINK-34559] Limit Global & Local Aggregation buffers

2

## What is the purpose of the change ``` Limit Global Aggregation buffers In case of large windows and/or lagging watermarks, RecordsWindowBuffer processes buffered records and flushes the state during...

[FLINK-35556] Fix constant in RocksDBSharedResourcesFactory.SLOT_SHARED_MANAGED

1

## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring...