Hi De Xun, I created an answer in the StackOverflow and hope it would be helpful. I’d like repost my answer here for the convenience of people in mailing lists.
The first call of RowRowConverter::toInternal is an internal implementation for making a deep copy of the StreamRecord emitted by table source, which is independent from the converter in your map function. The reason of the NPE is that the RowRowConverter in the map function is not initialized by calling RowRowConverter::open. You can use RichMapFunction instead to invoke the RowRowConverter::open in RichMapFunction::open. Best regards, Qingsheng Ren > On Mar 7, 2022, at 09:16, Chia De Xun . <dexun.c...@bytedance.com> wrote: > > Greetings, > > I'm facing a difficult issue/bug while working with Flink. Would definitely > appreciate some official expert help on this issue. I have posted my problem > on StackOverflow, but have no replies at the moment. > > Let me know if you have any questions/clarifications for me! It would be best > appreciated. > > Best Regards, > De Xun
