Integrating LLMs into apache flink pipelines

Hi Everyone, I've been experimenting with integrating LLMs into ETL and data pipelines to leverage the models for data processing. And I've created a blog post with a example pipeline to integrate openai models using langchian-beam library's transforms and load data and perform sentiment analysis

[VOTE] FLIP-506: Support Reuse Multiple Table Sinks in Planner

Hi all, I would like to start the vote for FLIP-506: Support Reuse Multiple Table Sinks in Planner[1]. This FLIP was discussed in this thread [2]. The vote will be open for at least 72 hours unless there is an objection or insufficient votes. [1] https://cwiki.apache.org/confluence/display/FLINK

[jira] [Created] (FLINK-37371) Postgres CDC incremental source fails to handle upper-case table and column names

Sergei Morozov created FLINK-37371: -- Summary: Postgres CDC incremental source fails to handle upper-case table and column names Key: FLINK-37371 URL: https://issues.apache.org/jira/browse/FLINK-37371