[DISCUSS] Hive dialect shouldn't fall back to Flink's default dialect

Hi, community . I want to start the discussion about Hive dialect shouldn't fall back to Flink's default dialect. Currently, when the HiveParser fail to parse the sql in Hive dialect, it'll fall back to Flink's default parser[1] to handle flink-specific statements like "CREATE CATALOG xx wit

Re: [ANNOUNCE] Apache Flink 1.16.2 released

Hi Jing, Thank you for caring about the releasing process. It has to be said that the entire process went smoothly. We have very comprehensive documentation[1] to guide my work, thanks to the contribution of previous release managers and the community. Regarding the obstacles, I actually only hav

Re: Backpressure handling in FileSource APIs - Flink 1.16

Hi Kamal, The network buffer will be full for specific `FileSource` when the job has back pressure which will block the source subtask. You can refer to network buffer [1] for more information. [1] https://flink.apache.org/2019/06/05/a-deep-dive-into-flinks-network-stack/ Best, Shammon FY On F