GoogleCloudPlatform / flink-on-k8s-operator

[DEPRECATED] Kubernetes operator for managing the lifecycle of Apache Flink and Beam applications.
Apache License 2.0
658 stars 266 forks source link

Inspecting Flink Cluster State used by the Operator #457

Open yashganti opened 3 years ago

yashganti commented 3 years ago

Hello,

We are new to using the operator and have been running a few jobs in production. We don't have HA mode enabled yet and have observed that a few times after our JM crashes and we redeploy the application, the new job doesn't start from a savepoint. In a few cases the fromSavePoint location seems to be automatically set by the operator (we see this in the arguments to flink-submit). Where in Kubernetes can I inspect the state that the operator is using when I kick off new deployments.