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: PyFlink and parallelism

It's not the issue with Python-Java object conversion, you get a DataStream rather than SingleOutputStreamOperator underlying the Python DataStream wrapper after calling `to_data_stream`, and `setParallelism` is only available on SingleOutputStreamOperator. To work around this, change `set_parallel

Re: [State Processor API] unable to load the state of a trigger attached to a session window

, but WindowReaderOperator only tries to find keys and namespaces related to window state. " Juntao Hu 于2022年5月12日周四 11:47写道： > After a little inspection, I found that elements (window state) are stored > in namespace TimeWindow{start=1,end=11}, in your case, and trigger count > (trigger