Ricco Førgaard
05/16/2023, 8:06 AMConfig option 'state.checkpoint-storage' is ignored because the checkpoint storage passed via StreamExecutionEnvironment takes precedence
However, I don't understand where this gets passed via StreamExecutionEnvironment. All I have in my code is
val env = StreamExecutionEnvironment.getExecutionEnvironment
and I don't make any changes to it besides setting max parallelism. Any ideas?