Hi! This does not sound like an expected behavior. However there might be a lot of reasons causing some values to be uninitialized (for example, once I've met a bug that a thread is created and runs in the open method before some values are initialized). You can always add some log at the beginning of the open 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 <gil.amsa...@booking.com> 于2021年8月8日周日 下午7:54写道： > Hi, > > I have a class that implements KafkaDeserializationSchema and overrides > the open() method. > When deploying my job, everything seems to work as expected. > But, when my task hit an exception and switch to CANCELED -> CREATED -> > DEPLOYING, it seems that the open method is not called, and I am ending up > with uninitialized values. > > Is that expected? Is it a bug? > > -- > Gil Amsalem > >
