Re: [External] Re: KafkaDeserializationSchema.open() is not called after task state change

2021-08-09 Thread Gil Amsalem
en method and see if it is really not called. If it is the case > then it should be a bug and the developers should look into it. > > Gil Amsalem 于2021年8月8日周日 下午7:54写道: > >> Hi, >> >> I have a class that implements KafkaDeserializationSchema and overrides >> the ope

KafkaDeserializationSchema.open() is not called after task state change

2021-08-08 Thread Gil Amsalem
d I am ending up with uninitialized values. Is that expected? Is it a bug? -- Gil Amsalem

Kubernetes Setup - JM as job vs JM as deployment

2021-04-21 Thread Gil Amsalem
Hi, I found that there are 2 different approaches to setup Flink over kubernetes. 1. Deploy job manager as Job. 2. Deploy job manager as Deployment. What is the recommended way? What are the benefits of each? Thanks, Gil Amsalem