Re: Reusing the same OutputTag in multiple ProcessFunctions

Wow thank you so much! Good to know its not just me. At the end of my day yesterday, I started sniffing this out too. I think I effectively did the same thing as setting _j_typeinfo to None by manually recreating the _j_typeinfo in a new ('cloned') output tag: from pyflink.common.typeinfo impor

Re: Reusing the same OutputTag in multiple ProcessFunctions

Hi Andrew, I've found out that this's a bug brought by another bugfix FLINK-29681 , I've created an issue FLINK-31083 for this problem. You could temporarily set inner java type_info to None befo

Re: Reusing the same OutputTag in multiple ProcessFunctions

I can't respond to the python-specific aspects of this situation, but I don't believe you need to use the same OutputTag instance. It should be enough that the various tag instances involved all have the same String id. (That's why the id exists.) David On Tue, Feb 14, 2023 at 11:51 AM Andrew Ott