Re: PyFlink DataStream union type mismatch

Hi Wouter, 1. These configurations work for both Python Table API and DataStream API. It seems targeted for Python Table API as only Python Table API is supported when adding the documentation. I will followup to improve the paragraph. 2. The recommended way is using `stream_execution_environme

Re: PyFlink DataStream union type mismatch

Hi Dian, all, Thanks, that indeed solved my problem. I have two more questions, I'm not sure if it is better practice to send a new email to the mailing list or to re-use a thread: 1. I noticed very high latency (multiple seconds per message) for a job with multiple operators and very low through

Re: PyFlink DataStream union type mismatch

Hi Wouter, 1) For the exception, it seems a bug. I have filed a ticket for it: https://issues.apache.org/jira/browse/FLINK-22733 2) Regarding to your requirements, I guess you should do it as following: ``` init_stream = (operator_stream .f