In this case there seems to be a bug. Please open a ticket in JIRA for that
and please describe the situation more thoroughly in the ticket. If
possible please also provide your user code and the exception message.
Thanks.
Gil Amsalem 于2021年8月9日周一 下午5:20写道：
> Hi Caizhi,
> Thanks for your reply.
Hi Caizhi,
Thanks for your reply.
I already have some traces in the open() methods, and I do not see that it
is being called.
We are using Flink version 1.11.2.
Should I open a bug for that?
On Mon, Aug 9, 2021 at 5:24 AM Caizhi Weng wrote:
> Hi!
>
> This does not sound like an expected behavio
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 beginnin
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 endin
