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
