Re: [External] : Re: StopWithSavepoint() method doesn't work in Java based flink native k8s operator

rnal] : Re: StopWithSavepoint() method doesn't work in Java based flink native k8s operator Since your problem is about the flink-native-k8s-operator, let's move the discussion there. Best, Yang Fuyao Li mailto:fuyao...@oracle.com>> 于2021年5月8日周六 上午5:41写道： Hi Austin, Yang, Matth

Re: [External] : Re: StopWithSavepoint() method doesn't work in Java based flink native k8s operator

ors/FlinkConfMountDecorator.java > > > > Have a good weekend! > > Best, > > Fuyao > > > > > > *From: *Fuyao Li > *Date: *Tuesday, May 4, 2021 at 19:52 > *To: *Austin Cawley-Edwards , > matth...@ververica.com , Yang Wang < > danrtsey...@gmail

Re: [External] : Re: StopWithSavepoint() method doesn't work in Java based flink native k8s operator

Cawley-Edwards , matth...@ververica.com , Yang Wang Cc: user Subject: Re: [External] : Re: StopWithSavepoint() method doesn't work in Java based flink native k8s operator Hello All, I also checked the native-k8s’s automatically generated configmap. It only contains the flink-conf.yaml, b

Re: [External] : Re: StopWithSavepoint() method doesn't work in Java based flink native k8s operator

: StopWithSavepoint() method doesn't work in Java based flink native k8s operator Hello Austin, Yang, For the logging issue, I think I have found something worth to notice. They are all based on base image flink:1.12.1-scala_2.11-java11 Dockerfile: https://pastebin.ubuntu.com/p/JTsHy

Re: [External] : Re: StopWithSavepoint() method doesn't work in Java based flink native k8s operator

] : Re: StopWithSavepoint() method doesn't work in Java based flink native k8s operator Hello All, For Logging issue: Hi Austin, This is the my full code implementation link [1], I just removed the credential related things. The operator definition can be found here.[2] You can also check

Re: [External] : Re: StopWithSavepoint() method doesn't work in Java based flink native k8s operator

14:47 To: matth...@ververica.com Cc: Fuyao Li , user , Yang Wang , Austin Cawley-Edwards Subject: [External] : Re: StopWithSavepoint() method doesn't work in Java based flink native k8s operator Hey all, Thanks for the ping, Matthias. I'm not super familiar with the details of @

Re: StopWithSavepoint() method doesn't work in Java based flink native k8s operator

gt;> >> For the log issue, I am still a bit confused. Why it is not available in >> kubectl logs. How should I get access to it? >> >> >> >> Thanks. >> >> Best, >> >> Fuyao >> >> >> >> *From: *Fuyao Li >>

Re: StopWithSavepoint() method doesn't work in Java based flink native k8s operator

ailable in > kubectl logs. How should I get access to it? > > > > Thanks. > > Best, > > Fuyao > > > > *From: *Fuyao Li > *Date: *Sunday, May 2, 2021 at 00:36 > *To: *user , Yang Wang > *Subject: *[External] : Re: StopWithSavepoint() method does

Re: StopWithSavepoint() method doesn't work in Java based flink native k8s operator

: [External] : Re: StopWithSavepoint() method doesn't work in Java based flink native k8s operator Hello, I noticed that first trigger a savepoint and then delete the deployment might cause the duplicate data issue. That could pose a bad influence to the semantic correctness. Please give me some hin

Re: StopWithSavepoint() method doesn't work in Java based flink native k8s operator

perform this image update operation. Thanks! Best, Fuyao From: Fuyao Li Date: Friday, April 30, 2021 at 18:03 To: user , Yang Wang Subject: [External] : Re: StopWithSavepoint() method doesn't work in Java based flink native k8s operator Hello Community, Yang, I have one more questio

Re: StopWithSavepoint() method doesn't work in Java based flink native k8s operator

rversAvailable: Subscription time out The logs stops here, flink applications logs doesn’t get printed here anymore----- Best, Fuyao From: Fuyao Li Date: Friday, April 30, 2021 at 16:50 To: user , Yang Wang Subject: [External] : StopWithSavepoint() method doesn't work in

StopWithSavepoint() method doesn't work in Java based flink native k8s operator

Hello Community, Yang, I am trying to extend the flink native Kubernetes operator by adding some new features based on the repo [1]. I wrote a method to release the image update functionality. [2] I added the triggerImageUpdate(oldFlinkApp, flinkApp, effectiveConfig); under the existing method.