flink
flink copied to clipboard
[WIP][FLINK-26372][runtime][state] Allow to configure Changelog Storage per program
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 factory is used on JM.
On TM, its configuration is combined with the one from job.
The path in common cases is as follows:
env -> streamGraphGenerator -> streamGraph -> jobGraph -> TM
CI report:
- 744456529cf24c5bc299e732c3d3c7e7c13a8201 Azure: FAILURE
Bot commands
The @flinkbot bot supports the following commands:-
@flinkbot run azure
re-run the last Azure build
Superseded by #21637.