Re: Job gets stuck when using kafka transactions and eventually crashes

2023-01-23 Thread Vishal Surana
Could it be that link is unable to commit offsets to Kafka? I know that blinks checkpoint mechanism isn’t tied to its ability to commit offset but at the same time, we’ve seen that the job can take hours to commit offsets while checkpoints go through successfully during that period. But with Kaf

Re: Flink Kubernetes Operator podTemplate and 'app' pod label bug?

2023-01-23 Thread Andrew Otto
Thanks all, I'm using other labels instead. Specifically, I'm using the component label to select the pods I need for my networkpolicies. - I agree that it would probably be best if flink k8s native did not use this label. - It would be nice if there was a common label applied to all pods create