Thomas Weise
Thomas Weise
@abossert looks like a different error than what is shown in the CI. How are you running the tests? Try `mvn clean install` if that's not what you are doing...
@abossert thanks for the contribution. Seeing no activity on the PR since Jan, what's the plan forward?
@anandswaminathan we should support jobs that don't enable checkpointing. There are also streaming use cases where it makes sense to not enable checkpointing.
https://github.com/lyft/flinkk8soperator/issues/138
Is this still an issue? We are using the operator with a Beam streaming job that does not have checkpointing enabled and also recently added the option to skip savepoint...
Just a note that I'm going to follow-up on this. But in the meantime, a generalized sidecar container concept in the CRD would probably also benefit other Flink applications.
@chadrik the main advantage is that sidecar would allow to use the stock SDK container images independent of Flink. This might become more important as we move to cross-language pipelines....
@chadrik the example is pretty much ready to go, waiting for the 2.17 Beam release: https://github.com/lyft/flinkk8soperator/pull/134
Hi, on the TM pod, you should see the Beam SDK worker process. Did Flink job start/terminate (check Flink UI)?
Commit should have a single author so that the contributor stats are not messed up. Work can be split into multiple commits if that is necessary.