I'm running a simple Flink 1.15 job in Kubernetes ...
# troubleshooting
r
I'm running a simple Flink 1.15 job in Kubernetes using the Flink Operator and I see this in the logs:
Copy code
Config 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
Copy code
val env = StreamExecutionEnvironment.getExecutionEnvironment
and I don't make any changes to it besides setting max parallelism. Any ideas?