dev

Messages by Date

2025/08/21 Re: [VOTE] FLIP-535: Introduce RateLimiter to Source Poorvank Bhatia
2025/08/21 Re: [VOTE] FLIP-541 Making PyFlink more Pythonic (Phase-1) Jacky Lau
2025/08/21 [jira] [Created] (FLINK-38273) Flink SQL Client Embedded Mode Configuration Regression in 1.19 - Connection fails when rest.bind-port is configured shml (Jira)
2025/08/21 Re: [VOTE] FLIP-541 Making PyFlink more Pythonic (Phase-1) Zakelly Lan
2025/08/21 Re: [VOTE] FLIP-541 Making PyFlink more Pythonic (Phase-1) Geng Biao
2025/08/21 Re: Re: [DISCUSS] Add UDF Metrics Zakelly Lan
2025/08/20 Re: [VOTE] FLIP-535: Introduce RateLimiter to Source Leonard Xu
2025/08/20 Re: [ANNOUNCE] New Apache Flink PMC Member - Ron Liu Ron Liu
2025/08/20 Re: [VOTE] FLIP-541 Making PyFlink more Pythonic (Phase-1) Xingbo Huang
2025/08/20 Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Becket Qin
2025/08/20 Re: [VOTE] FLIP-541 Making PyFlink more Pythonic (Phase-1) Anirudh Prabhakaran
2025/08/20 Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Hongshun Wang
2025/08/20 Re: [VOTE] FLIP-540: Support VECTOR_SEARCH in Flink SQL Shengkai Fang
2025/08/20 Re: [VOTE] FLIP-535: Introduce RateLimiter to Source Shengkai Fang
2025/08/20 Re: [VOTE] FLIP-541 Making PyFlink more Pythonic (Phase-1) Shengkai Fang
2025/08/20 [VOTE] FLIP-535: Introduce RateLimiter to Source Zexian WU
2025/08/20 Re: [VOTE] FLIP-541 Making PyFlink more Pythonic (Phase-1) Dian Fu
2025/08/20 [VOTE] FLIP-541 Making PyFlink more Pythonic (Phase-1) Zander Matheson
2025/08/20 Re: [ANNOUNCE] New Apache Flink PMC Member - Ron Liu Ramin Gharib
2025/08/20 Re: [VOTE] Release flink-connector-kafka v4.0.1, release candidate #2 Fabian Paul
2025/08/20 [SUMMARY] Flink 2.2 Release Sync 08/20/2025 Hang Ruan
2025/08/20 Re: [DISCUSS] FLIP-490: Enhanced Job History Retention Policies for HistoryServer Yuepeng Pan
2025/08/19 Re: [DISCUSS] FLIP-490: Enhanced Job History Retention Policies for HistoryServer Becket Qin
2025/08/19 [jira] [Created] (FLINK-38272) The BatchJobRecoveryTest failed of azure cron adaptive scheduler pipeline Ruan Hang (Jira)
2025/08/19 Re: [VOTE] FLIP-540: Support VECTOR_SEARCH in Flink SQL Yash Anand
2025/08/19 [jira] [Created] (FLINK-38271) PostgresSQL pipeline supports table schema evolution. ouyangwulin (Jira)
2025/08/19 Re: [VOTE] FLIP-540: Support VECTOR_SEARCH in Flink SQL Jacky Lau
2025/08/19 Re: [DISCUSS] FLIP-542: Support DISTRIBUTED BY/INTO for Materialized tables Ron Liu
2025/08/19 Re: [VOTE] FLIP-540: Support VECTOR_SEARCH in Flink SQL Lincoln Lee
2025/08/19 [jira] [Created] (FLINK-38270) MySQL CDC source may ignore newly added tables while reading the binlog (scenario 2) Sergei Morozov (Jira)
2025/08/19 [jira] [Created] (FLINK-38269) Make Job Manager's REST endpoint advertised address configurable Yaroslav (Jira)
2025/08/19 Re: [VOTE] Release flink-connector-kafka v4.0.1, release candidate #2 Sergey Nuyanzin
2025/08/19 Re: [ANNOUNCE] New Apache Flink PMC Member - Ron Liu Hao Li
2025/08/19 Re: [VOTE] FLIP-540: Support VECTOR_SEARCH in Flink SQL Hao Li
2025/08/19 Re: [VOTE] FLIP-540: Support VECTOR_SEARCH in Flink SQL Mingge Deng
2025/08/19 Re: [VOTE] FLIP-540: Support VECTOR_SEARCH in Flink SQL Weiqing Yang
2025/08/19 Re: [VOTE] FLIP-540: Support VECTOR_SEARCH in Flink SQL dylanhz
2025/08/19 Re: [VOTE] Release flink-connector-kafka v4.0.1, release candidate #2 Weiqing Yang
2025/08/19 Re: [VOTE] FLIP-540: Support VECTOR_SEARCH in Flink SQL Timo Walther
2025/08/19 Re: [DISCUSS] State Schema Evolution for RowData Gabor Somogyi
2025/08/19 Re: [VOTE] Release flink-connector-kafka v4.0.1, release candidate #2 Fabian Paul
2025/08/19 Re: [DISCUSS] Proposal: Enabling Flamegraph via UI (Dynamic) Poorvank Bhatia
2025/08/19 [jira] [Created] (FLINK-38268) Incorrect serialization of VARIANT type FLOAT Timo Walther (Jira)
2025/08/19 Re: [DISCUSS] Proposal: Enabling Flamegraph via UI (Dynamic) Poorvank Bhatia
2025/08/19 [jira] [Created] (FLINK-38267) Job cannot be recovered from unaligned checkpoint after rescaling when one task has multiple exchanges Rui Fan (Jira)
2025/08/19 Re: [DISCUSS] Proposal: Enabling Flamegraph via UI (Dynamic) Gyula Fóra
2025/08/19 Re: [DISCUSS] Proposal: Enabling Flamegraph via UI (Dynamic) Danny Cranmer
2025/08/19 [jira] [Created] (FLINK-38266) SQL Gateway - mask sensitive table and catalog options Jira
2025/08/19 Re: [DISCUSS] FLIP-495: Support AdaptiveScheduler record and query the rescale history Yuepeng Pan
2025/08/19 Re: [DISCUSS] FLIP-542: Support DISTRIBUTED BY/INTO for Materialized tables Gustavo de Morais
2025/08/18 [DISCUSS] FLIP-XXX: Hardening the Event Reporter with an Asynchronous Core Kartikey Pant
2025/08/18 [jira] [Created] (FLINK-38265) Stream Split shouldn't finish when exception occors Hongshun Wang (Jira)
2025/08/18 Re: [VOTE] FLIP-485: Add UDF Metrics Yuepeng Pan
2025/08/18 [VOTE] FLIP-540: Support VECTOR_SEARCH in Flink SQL Shengkai Fang
2025/08/18 Re: [VOTE] FLIP-485: Add UDF Metrics Shengkai Fang
2025/08/18 Re: [DISCUSS] FLIP-540: Support VECTOR_SEARCH in Flink SQL Shengkai Fang
2025/08/18 Re: [DISCUSS] Add SQL module dynamic function loading possibility Zsombor Chikán
2025/08/18 Re: [DISCUSS] FLIP-490: Enhanced Job History Retention Policies for HistoryServer Yuepeng Pan
2025/08/18 Re: [DISCUSS] FLIP-542: Support DISTRIBUTED BY/INTO for Materialized tables Sergey Nuyanzin
2025/08/18 Re: [DISCUSS] FLIP-542: Support DISTRIBUTED BY/INTO for Materialized tables Hao Li
2025/08/18 [jira] [Created] (FLINK-38264) Connection table api Hao Li (Jira)
2025/08/18 [jira] [Created] (FLINK-38263) Connection and secret factory Hao Li (Jira)
2025/08/18 [jira] [Created] (FLINK-38262) Convert connection sqlnode to operations Hao Li (Jira)
2025/08/18 [jira] [Created] (FLINK-38261) Connection catalog object and manager changes Hao Li (Jira)
2025/08/18 [jira] [Created] (FLINK-38260) Connection sql syntax Hao Li (Jira)
2025/08/18 [jira] [Created] (FLINK-38259) FLIP-529: Connections in Flink SQL and TableAPI Hao Li (Jira)
2025/08/18 Re: [DISCUSS] Add SQL module dynamic function loading possibility Gabor Somogyi
2025/08/18 Re: [ANNOUNCE] New Apache Flink PMC Member - Ron Liu Sergey Nuyanzin
2025/08/18 Re: [DISCUSS] Add SQL module dynamic function loading possibility Zsombor Chikán
2025/08/18 Re: [VOTE] Release flink-connector-kafka v4.0.1, release candidate #2 Sergey Nuyanzin
2025/08/18 [jira] [Created] (FLINK-38258) Enable model param for PTF Hao Li (Jira)
2025/08/18 Re: [DISCUSS] FLIP-490: Enhanced Job History Retention Policies for HistoryServer Becket Qin
2025/08/18 Re: [VOTE] Release flink-connector-kafka v4.0.1, release candidate #2 Martijn Visser
2025/08/18 Re: [DISCUSS] FLIP-542: Support DISTRIBUTED BY/INTO for Materialized tables Ramin Gharib
2025/08/18 Re: [VOTE] Release flink-connector-kafka v4.0.1, release candidate #2 Fabian Hueske
2025/08/18 [DISCUSS] Add SQL module dynamic function loading possibility Gabor Somogyi
2025/08/18 [jira] [Created] (FLINK-38257) Add module dynamic function loading possibility Gabor Somogyi (Jira)
2025/08/18 Re:[DISCUSS] FLIP-538: Support Custom Generic Type Serializer Yuepeng Pan
2025/08/18 [jira] [Created] (FLINK-38256) Sync unparse for Table and SHOW CREATE TABLE Sergey Nuyanzin (Jira)
2025/08/18 Re: [DISCUSS] FLIP-542: Make materialized table DDL consistent with regular tables Sergey Nuyanzin
2025/08/18 Re: [ANNOUNCE] New Apache Flink PMC Member - Ron Liu Jingsong Li
2025/08/18 Re: [DISCUSS] FLIP-540: Support VECTOR_SEARCH in Flink SQL Timo Walther
2025/08/17 退订陈佳豪
2025/08/17 [VOTE] FLIP-485: Add UDF Metrics Weiqing Yang
2025/08/17 [jira] [Created] (FLINK-38255) Add ITCase to verify sensitive table option redaction Yang Li (Jira)
2025/08/16 [jira] [Created] (FLINK-38254) Hidding sensitive information Yang Li (Jira)
2025/08/15 Re: [DISCUSS] FLIP-542: Support DISTRIBUTED BY/INTO for Materialized tables Timo Walther
2025/08/15 [DISCUSS] FLIP-542: Support DISTRIBUTED BY/INTO for Materialized tables Sergey Nuyanzin
2025/08/15 [jira] [Created] (FLINK-38253) Allow usage of vertx/jdk/jetty/okhttp clients in fabric8 in flink-kubernetes Jakub Stejskal (Jira)
2025/08/15 Re: [ANNOUNCE] New Apache Flink PMC Member - Ron Liu David Radley
2025/08/15 Re: [DISCUSS] FLIP-540: Support VECTOR_SEARCH in Flink SQL Shengkai Fang
2025/08/15 [jira] [Created] (FLINK-38252) ResourceManager will not apply for a new pod when pending pod is deleted Baozhu Zhao (Jira)
2025/08/15 [jira] [Created] (FLINK-38251) Fix recompilation of restore tests for MultiJoinTestPrograms Timo Walther (Jira)
2025/08/15 Re: [DISCUSS] Planning Flink 2.2 Hang Ruan
2025/08/15 [jira] [Created] (FLINK-38250) The Flink CDC type supports the timeTZ field type. ouyangwulin (Jira)
2025/08/15 Re: [DISCUSS] FLIP-540: Support VECTOR_SEARCH in Flink SQL Timo Walther
2025/08/15 [jira] [Created] (FLINK-38249) Flink CDC should let users configure Debezium’s 'skipped.operations' parameter to filter out unwanted binlog operations. Hao Yu (Jira)
2025/08/14 Re: [DISCUSS] FLIP-540: Support VECTOR_SEARCH in Flink SQL Shengkai Fang
2025/08/14 Re: Re: [DISCUSS] Add UDF Metrics Weiqing Yang
2025/08/14 Re: Flink Connector Kafka Releases Weiqing Yang
2025/08/14 Re: [DISCUSS] FLIP-490: Enhanced Job History Retention Policies for HistoryServer Allison
2025/08/14 Re: [DISCUSS] FLIP-490: Enhanced Job History Retention Policies for HistoryServer Yuepeng Pan
2025/08/14 [jira] [Created] (FLINK-38248) The default value of '0000-00-00 00:00:00' for MySQL TIMESTAMP fields is not supported in downstream systems. Yanquan Lv (Jira)
2025/08/14 [jira] [Created] (FLINK-38247) MySqlChunkSplitter may continuously generate splits when using BIGINT UNSIGNED as primary key Yanquan Lv (Jira)
2025/08/14 Re: [DISCUSS] FLIP-490: Enhanced Job History Retention Policies for HistoryServer Ryan van Huuksloot
2025/08/14 Re: [DISCUSS] FLIP-490: Enhanced Job History Retention Policies for HistoryServer Yuepeng Pan
2025/08/14 Re: [DISCUSS] FLIP-490: Enhanced Job History Retention Policies for HistoryServer Ryan van Huuksloot
2025/08/14 Re: [DISCUSS] FLIP-490: Enhanced Job History Retention Policies for HistoryServer Yuepeng Pan
2025/08/14 Re: [DISCUSS] FLIP-490: Enhanced Job History Retention Policies for HistoryServer Ryan van Huuksloot
2025/08/14 Re: [DISCUSS] FLIP-490: Enhanced Job History Retention Policies for HistoryServer Yuepeng Pan
2025/08/14 Re: [DISCUSS] FLIP-540: Support VECTOR_SEARCH in Flink SQL Timo Walther
2025/08/14 [jira] [Created] (FLINK-38246) Remove unreachable code in CodeGenUtils morvenhuang (Jira)
2025/08/14 [jira] [Created] (FLINK-38245) FLIP-532: Donate GetInData HTTP Connector to Flink david radley (Jira)
2025/08/14 Re: [ANNOUNCE] New Apache Flink PMC Member - Ron Liu yunhong Zheng
2025/08/14 Clarification question on stateful upgrades and evolutlion David Radley
2025/08/14 Re: [VOTE] Release flink-connector-kafka v4.0.1, release candidate #2 Fabian Paul
2025/08/14 2025/08/14 CHI Eastern time zone workgroup meeting minutes David Radley
2025/08/14 Re: Flink Connector Kafka Releases Fabian Paul
2025/08/14 Re: [ANNOUNCE] New Apache Flink PMC Member - Ron Liu Gustavo de Morais
2025/08/14 Re: [DISCUSS] Planning Flink 2.2 Gustavo de Morais
2025/08/14 Re: Re: [DISCUSS] Add UDF Metrics Shengkai Fang
2025/08/13 Re: Re: [DISCUSS] Add UDF Metrics Weiqing Yang
2025/08/13 Re: [DISCUSS] Planning Flink 2.2 Hongshun Wang
2025/08/13 Re: [ANNOUNCE] New Apache Flink PMC Member - Ron Liu Hongshun Wang
2025/08/13 Re: [ANNOUNCE] New Apache Flink PMC Member - Ron Liu Geng Biao
2025/08/13 [jira] [Created] (FLINK-38244) When the table name of mysql supports size sensitive, fix the error that column name not being found Hongshun Wang (Jira)
2025/08/13 [jira] [Created] (FLINK-38243) When the table name of mysql supports size sensitive, fix the error that column name not being found Hongshun Wang (Jira)
2025/08/13 [jira] [Created] (FLINK-38242) Improve upgrading documentation for SQL/Table API state compatibility and add Flink 2.x to compatibility table Weiqing Yang (Jira)
2025/08/13 Re: [ANNOUNCE] New Apache Flink PMC Member - Ron Liu Zakelly Lan
2025/08/13 Re: Re: [DISCUSS] Add UDF Metrics Shengkai Fang
2025/08/13 [jira] [Created] (FLINK-38241) Dispatcher throws FlinkJobNotFoundException when `requestCheckpointStats` for a FINISHED stream job junzhong qin (Jira)
2025/08/13 [jira] [Created] (FLINK-38240) Dispatcher throws FlinkJobNotFoundException when `requestCheckpointStats` for a FINISHED stream job junzhong qin (Jira)
2025/08/13 Re: [DISCUSS] FLIP-540: Support VECTOR_SEARCH in Flink SQL Shengkai Fang
2025/08/13 Re: [ANNOUNCE] New Apache Flink PMC Member - Ron Liu Zhanghao Chen
2025/08/13 Re: Flink Connector Kafka Releases Weiqing Yang
2025/08/13 Re: Re: [DISCUSS] Add UDF Metrics Weiqing Yang
2025/08/13 Re: [DISCUSS] Planning Flink 2.2 Weiqing Yang
2025/08/13 Re: [ANNOUNCE] New Apache Flink PMC Member - Ron Liu Weiqing Yang
2025/08/13 Backport label David Radley
2025/08/13 [jira] [Created] (FLINK-38239) Enable Disabled OceanBase CDC Integration Tests in GitHub CI yuan (Jira)
2025/08/13 [jira] [Created] (FLINK-38238) Failed to process MySQL table with varchar(0) column Yanquan Lv (Jira)
2025/08/13 Re: [VOTE] Release flink-connector-kafka v4.0.1, release candidate #2 Hongshun Wang
2025/08/12 Re:Re: [DISCUSS] FLIP-495: Support AdaptiveScheduler record and query the rescale history Yuepeng Pan
2025/08/12 [jira] [Created] (FLINK-38237) MongoDB CDC - row_kind virtual column is returning incorrect operation Type Fabrizzio Chavez (Jira)
2025/08/12 Re: [ANNOUNCE] New Apache Flink PMC Member - Ron Liu Jacky Lau
2025/08/12 Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Hongshun Wang
2025/08/12 Re: [ANNOUNCE] New Apache Flink PMC Member - Ron Liu Shengkai Fang
2025/08/12 Re: [VOTE] Release flink-connector-kafka v4.0.1, release candidate #2 Zexian WU
2025/08/12 Re: [ANNOUNCE] New Apache Flink PMC Member - Ron Liu Hang Ruan
2025/08/12 Re:Re: [ANNOUNCE] New Apache Flink PMC Member - Ron Liu Xuyang
2025/08/12 Re: [ANNOUNCE] New Apache Flink PMC Member - Ron Liu Leonard Xu
2025/08/12 Re: [ANNOUNCE] New Apache Flink PMC Member - Ron Liu Feng Jin
2025/08/12 Re: [ANNOUNCE] New Apache Flink PMC Member - Ron Liu Xiqian YU
2025/08/12 Re:[ANNOUNCE] New Apache Flink PMC Member - Ron Liu dylanhz
2025/08/12 Re: [ANNOUNCE] New Apache Flink PMC Member - Ron Liu Yuepeng Pan
2025/08/12 Re: [ANNOUNCE] New Apache Flink PMC Member - Ron Liu Yanquan Lv
2025/08/12 [ANNOUNCE] New Apache Flink PMC Member - Ron Liu Lincoln Lee
2025/08/12 [jira] [Created] (FLINK-38236) MongoDB CDC - Include Full Document as Metadata Field Fabrizzio Chavez (Jira)
2025/08/12 [jira] [Created] (FLINK-38235) Unable to reliably detect newly added tables with MySQL CDC Max Feng (Jira)
2025/08/12 Re: [DISCUSS] Planning Flink 2.2 Ron Liu
2025/08/12 Re: [DISCUSS] Planning Flink 2.2 Lincoln Lee
2025/08/12 [jira] [Created] (FLINK-38234) Enable nondeterministic update strategy by default in SemanticTestBase Gustavo de Morais (Jira)
2025/08/12 [jira] [Created] (FLINK-38233) Implement visitProcessTableFunction for StreamNonDeterministicUpdatePlanVisitor Gustavo de Morais (Jira)
2025/08/12 [jira] [Created] (FLINK-38232) [docs] Update “Pipeline Connectors > Overview” to include Iceberg, Postgres, Fluss suhwan (Jira)
2025/08/12 [jira] [Created] (FLINK-38231) Standardise use of uv for PyFlink building/testing/tooling Mika Naylor (Jira)
2025/08/12 Re: [DISCUSS] FLIP-535:Introduce RateLimiter to Source Leonard Xu
2025/08/12 Re: [KINDLY REMINDER] Flink CDC 3.5.0 Feature Freeze Leonard Xu
2025/08/12 [jira] [Created] (FLINK-38230) Implement visitMultiJoin for StreamNonDeterministicUpdatePlanVisitor Gustavo de Morais (Jira)
2025/08/12 [jira] [Created] (FLINK-38229) FLIP-490: Enhanced Job History Retention Policies for HistoryServer RocMarshal (Jira)
2025/08/12 [jira] [Created] (FLINK-38228) To ensure consistent aggregation results in the window operator, we need to consider state TTL; otherwise, we must send messages to downstream operators to prevent their state from expiring prematurely. Jacky Lau (Jira)
2025/08/11 Re: [DISCUSS] Planning Flink 2.2 Zakelly Lan
2025/08/11 [jira] [Created] (FLINK-38227) Flink-CDC Postgres with Incremental Change does not work Harish Sharma (Jira)
2025/08/11 [jira] [Created] (FLINK-38226) Kafka Sink Improvement: Add failOnError to Control Exception Behavio Ejaskhan (Jira)
2025/08/11 Proposal: Add failOnError option in KafkaSinkBuilder to suppress job restarts when DeliveryGuarantee.NONE is used Ejaskhan S
2025/08/11 [DISCUSS] Proposal: Enabling Flamegraph via UI (Dynamic) Poorvank Bhatia
2025/08/11 Re: Re: [DISCUSS] FLIP-535:Introduce RateLimiter to Source Zexian WU
2025/08/11 Re: Update `flink-connector-hive` for 2.0 and 2.1 version Xiaolong Wang
2025/08/11 Re: [DISCUSS] Planning Flink 2.2 Jark Wu
2025/08/11 [jira] [Created] (FLINK-38225) GSBlobStorageImpl needs to add precondition check to make 503 retryable Xi Zhang (Jira)
2025/08/11 Re: Flink Connector Kafka Releases Tom Cooper
2025/08/11 [jira] [Created] (FLINK-38224) Retract sink should not accept duplicate changes produced by delta join Xuyang Zhong (Jira)
2025/08/11 [jira] [Created] (FLINK-38223) testConstraintsAfterRestart is flaky on master Gustavo de Morais (Jira)
2025/08/11 [jira] [Created] (FLINK-38222) Upgrade HBase client version to 2.6 Mate Czagany (Jira)
2025/08/10 [jira] [Created] (FLINK-38221) PostgreSQL CDC fails to capture data from partition tables when configured with parent table names tchivs (Jira)
2025/08/10 [DISCUSS] FLIP-490: Enhanced Job History Retention Policies for HistoryServer Yuepeng Pan
2025/08/10 退订赵一帆
2025/08/10 [jira] [Created] (FLINK-38220) Adjust JoinToMultiJoinRule to support different types of source Gustavo de Morais (Jira)
2025/08/10 [jira] [Created] (FLINK-38219) Manipulate state in MultiJoin with fixed row kind Gustavo de Morais (Jira)
2025/08/10 Re: [DISCUSS] FLIP-495: Support AdaptiveScheduler record and query the rescale history Matthias Pohl
2025/08/08 Re: [Discuss][Proposal] Decouple the Debezium Connector from the Flink CDC Project João Boto
2025/08/08 [jira] [Created] (FLINK-38218) MySQL CDC source may ignore newly added tables while reading the binlog Sergei Morozov (Jira)
2025/08/08 [jira] [Created] (FLINK-38217) ChangelogNormalize unnecessarily emits updates for equal rows Dawid Wysakowicz (Jira)
2025/08/08 Re: [VOTE] Release flink-connector-kafka v4.0.1, release candidate #2 Robert Metzger
2025/08/08 [jira] [Created] (FLINK-38216) Refactor EndOfChannelStateEvent according to input buffer and output buffer Rui Fan (Jira)
2025/08/08 [KINDLY REMINDER] Flink CDC 3.5.0 Feature Freeze Yanquan Lv
2025/08/07 [jira] [Created] (FLINK-38215) Remove HA data according to config option `job.savepoint-on-deletion` when cleanup terminal JM after ttl passed junzhong qin (Jira)
2025/08/07 [jira] [Created] (FLINK-38214) Support Kinesis streams source in Python DataStream API Dian Fu (Jira)
2025/08/07 [jira] [Created] (FLINK-38213) Failed Yanquan Lv (Jira)
2025/08/07 [jira] [Created] (FLINK-38212) OOM during savepoint caused by potential memory leak issue in RocksDB related to jemalloc Grzegorz Liter (Jira)
2025/08/07 [jira] [Created] (FLINK-38211) Refactor explain for MultiJoin operator Gustavo de Morais (Jira)