flink icon indicating copy to clipboard operation
flink copied to clipboard

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

Open rkhachatryan opened this issue 2 years ago • 1 comments

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

rkhachatryan avatar Aug 09 '22 18:08 rkhachatryan

CI report:

  • 744456529cf24c5bc299e732c3d3c7e7c13a8201 Azure: FAILURE
Bot commands The @flinkbot bot supports the following commands:
  • @flinkbot run azure re-run the last Azure build

flinkbot avatar Aug 09 '22 18:08 flinkbot

Superseded by #21637.

rkhachatryan avatar Jan 25 '23 13:01 rkhachatryan