issues  

Messages by Date

• 2026/03/06 [jira] [Commented] (FLINK-39191) Upgrade monaco-editor to 0.55.1 to get rid of DOMPurify CVEs Gyula Komlossi (Jira)
• 2026/03/06 [jira] [Updated] (FLINK-39191) Upgrade monaco-editor to 0.55.1 to get rid of DOMPurify CVEs ASF GitHub Bot (Jira)
• 2026/03/06 [PR] [FLINK-39191][runtime-web] Upgrade monaco-editor to 0.55.1 [flink] via GitHub
• 2026/03/06 Re: [PR] [FLINK-38704][runtime] Convert config values to String [flink] via GitHub
• 2026/03/06 Re: [PR] [FLINK-21309][metrics] Add UUID as grouping key for prom pushgateway [flink] via GitHub
• 2026/03/06 Re: [PR] [FLINK-38704][runtime] Convert config values to String [flink] via GitHub
• 2026/03/06 [jira] [Updated] (FLINK-21309) Metrics of JobManager and TaskManager overwrite each other in pushgateway ASF GitHub Bot (Jira)
• 2026/03/06 [PR] [FLINK-21309][metrics] Add UUID as grouping key for prom pushgateway [flink] via GitHub
• 2026/03/06 Re: [PR] [FLINK-39081] Add ARTIFACT keyword option in CREATE FUNCTION's USING clause [flink] via GitHub
• 2026/03/06 [jira] [Resolved] (FLINK-39221) Add AGGREGATE_VALUES rule for constant folding of global aggregates Fabian Paul (Jira)
• 2026/03/06 Re: [PR] [FLINK-39221][table] Add AGGREGATE_VALUES rule for constant folding o… [flink] via GitHub
• 2026/03/06 Re: [PR] [FLINK-38704][runtime] Convert config values to String [flink] via GitHub
• 2026/03/06 Re: [PR] [Feature][Java] Add OpenAI Responses API integration [flink-agents] via GitHub
• 2026/03/06 Re: [PR] [FLINK-39081] Add ARTIFACT keyword option in CREATE FUNCTION's USING clause [flink] via GitHub
• 2026/03/06 Re: [PR] [FLINK-39081] Add ARTIFACT keyword option in CREATE FUNCTION's USING clause [flink] via GitHub
• 2026/03/06 Re: [PR] [FLINK-39081] Add ARTIFACT keyword option in CREATE FUNCTION's USING clause [flink] via GitHub
• 2026/03/06 Re: [PR] [FLINK-39081] Add ARTIFACT keyword option in CREATE FUNCTION's USING clause [flink] via GitHub
• 2026/03/06 Re: [PR] [FLINK-39081] Add ARTIFACT keyword option in CREATE FUNCTION's USING clause [flink] via GitHub
• 2026/03/06 [jira] [Updated] (FLINK-38920) create Table source and factory for DynamicKafkaSource in Flink Table API Ferenc Csaky (Jira)
• 2026/03/06 [jira] [Updated] (FLINK-39037) support query kafka cluster id as metadata in records of DynamicKafkaTableSource Ferenc Csaky (Jira)
• 2026/03/06 Re: [PR] [FLINK-38920] create Table source and factory for DynamicKafkaSource in Flink Table API [flink-connector-kafka] via GitHub
• 2026/03/06 [jira] [Updated] (FLINK-38999) License lineage files Ferenc Csaky (Jira)
• 2026/03/06 [jira] [Updated] (FLINK-39120) Update to Kafka 4.2.0 Ferenc Csaky (Jira)
• 2026/03/06 [jira] [Updated] (FLINK-39013) add E2E test for DynamicKafkaTableSource Ferenc Csaky (Jira)
• 2026/03/06 [jira] [Updated] (FLINK-38917) add doc of pyflink DynamicKafkaSource to flink-connector-kafka Ferenc Csaky (Jira)
• 2026/03/06 [jira] [Updated] (FLINK-38876) Support per-cluster offset in Dynamic Kafka Source Ferenc Csaky (Jira)
• 2026/03/06 [jira] [Updated] (FLINK-38471) flink-end-to-end-tests-common-kafka depends implicitely on kafka-sql-connector Ferenc Csaky (Jira)
• 2026/03/06 [jira] [Updated] (FLINK-37818) Kafka connector requires unqiue TransactionalIdPrefix even for non-EOS settings. Ferenc Csaky (Jira)
• 2026/03/06 [jira] [Updated] (FLINK-29245) [JUnit 5 Migration] Remove RetryRule Ferenc Csaky (Jira)
• 2026/03/06 [jira] [Updated] (FLINK-39012) Support global enumerator/dispatcher for dynamic Kafka source Ferenc Csaky (Jira)
• 2026/03/06 [jira] [Updated] (FLINK-37583) Upgrade Kafka Client version to 4.0.0 Ferenc Csaky (Jira)
• 2026/03/06 Re: [PR] [FLINK-38704][runtime] Convert config values to String [flink] via GitHub
• 2026/03/06 [jira] [Comment Edited] (FLINK-38704) Metrics reporter setup does not load Prometheus with correct configs/port Mukul Gupta (Jira)
• 2026/03/06 [jira] [Commented] (FLINK-38704) Metrics reporter setup does not load Prometheus with correct configs/port Mukul Gupta (Jira)
• 2026/03/06 Re: [PR] [FLINK-38704][runtime] Convert config values to String [flink] via GitHub
• 2026/03/06 Re: [PR] [FLINK-38729] Add support for Flink 2.2.0 [flink-cdc] via GitHub
• 2026/03/06 [jira] [Updated] (FLINK-38704) Metrics reporter setup does not load Prometheus with correct configs/port ASF GitHub Bot (Jira)
• 2026/03/06 [PR] [FLINK-38704][runtime] Convert config values to String [flink] via GitHub
• 2026/03/06 Re: [PR] [FLINK-39221][table] Add AGGREGATE_VALUES rule for constant folding o… [flink] via GitHub
• 2026/03/06 Re: [PR] Maximum parallelism expansion can be used in MAXIMIZE_UTILISATION mode. [flink-kubernetes-operator] via GitHub
• 2026/03/06 [PR] feat: Flink 2.2 compatibility and dual-dist packaging [flink-cdc] via GitHub
• 2026/03/06 [jira] [Resolved] (FLINK-39204) fluss yaml sink support add column at last Leonard Xu (Jira)
• 2026/03/06 Re: [PR] [FLINK-39204] Fluss yaml sink support add column at last. [flink-cdc] via GitHub
• 2026/03/06 Re: [PR] [FLINK-39204] Fluss yaml sink support add column at last. [flink-cdc] via GitHub
• 2026/03/06 Re: [PR] [FLINK-39221][table] Add AGGREGATE_VALUES rule for constant folding o… [flink] via GitHub
• 2026/03/06 Re: [PR] [FLINK-39221][table] Add AGGREGATE_VALUES rule for constant folding o… [flink] via GitHub
• 2026/03/06 Re: [PR] [FLINK-39220] Add unit tests for ConditionsUtils [flink-kubernetes-operator] via GitHub
• 2026/03/06 [jira] [Updated] (FLINK-39221) Add AGGREGATE_VALUES rule for constant folding of global aggregates ASF GitHub Bot (Jira)
• 2026/03/06 [PR] [FLINK-39221][table] Add AGGREGATE_VALUES rule for constant folding o… [flink] via GitHub
• 2026/03/06 Re: [PR] [FLINK-39220] Add unit tests for ConditionsUtils [flink-kubernetes-operator] via GitHub
• 2026/03/06 Re: [PR] [FLINK-39220] Add unit tests for ConditionsUtils [flink-kubernetes-operator] via GitHub
• 2026/03/06 Re: [PR] [FLINK-39220] Add unit tests for ConditionsUtils [flink-kubernetes-operator] via GitHub
• 2026/03/06 Re: [PR] [FLINK-39220] Add unit tests for ConditionsUtils [flink-kubernetes-operator] via GitHub
• 2026/03/06 Re: [PR] [FLINK-39220] Add unit tests for ConditionsUtils [flink-kubernetes-operator] via GitHub
• 2026/03/06 [jira] [Assigned] (FLINK-39220) Add tests for ConditionsUtils David Radley (Jira)
• 2026/03/06 [jira] [Created] (FLINK-39221) Add AGGREGATE_VALUES rule for constant folding of global aggregates Fabian Paul (Jira)
• 2026/03/06 [jira] [Assigned] (FLINK-39221) Add AGGREGATE_VALUES rule for constant folding of global aggregates Fabian Paul (Jira)
• 2026/03/06 Re: [PR] [FLINK-39220] Add unit tests for ConditionsUtils [flink-kubernetes-operator] via GitHub
• 2026/03/06 Re: [PR] [FLINK-39220] Add unit tests for ConditionsUtils [flink-kubernetes-operator] via GitHub
• 2026/03/06 Re: [PR] [FLINK-39220] Add unit tests for ConditionsUtils [flink-kubernetes-operator] via GitHub
• 2026/03/06 [jira] [Updated] (FLINK-39220) Add tests for ConditionsUtils ASF GitHub Bot (Jira)
• 2026/03/06 Re: [PR] [FLINK-39220] Add unit tests for ConditionsUtils [flink-kubernetes-operator] via GitHub
• 2026/03/06 Re: [PR] [FLINK-38959][pipeline-connector][postgres]Added support for schema change in the postgres pipeline connector [flink-cdc] via GitHub
• 2026/03/06 [jira] [Commented] (FLINK-39210) Memory Leak Issue in Flink SQL with Multiple Temporal Joins Timo Walther (Jira)
• 2026/03/06 Re: [PR] [MINOR] Update starrocks.md [flink-cdc] via GitHub
• 2026/03/06 Re: [PR] [FLINK-38729] Add support for Flink 2.2.0 [flink-cdc] via GitHub
• 2026/03/06 [PR] [FLINK-39152][pipeline-connector][Fluss]Fix FlussConfig Utils class is not in the correct directory and should have a private instance [flink-cdc] via GitHub
• 2026/03/06 Re: [PR] [FLINK-39152][pipeline-connector][Fluss]Fix FlussConfig Utils class is not in the correct directory and not have a private instance [flink-cdc] via GitHub
• 2026/03/06 [jira] [Assigned] (FLINK-39204) fluss yaml sink support add column at last Leonard Xu (Jira)
• 2026/03/06 Re: [PR] [FLINK-39204] Fluss yaml sink support add column at last. [flink-cdc] via GitHub
• 2026/03/05 Re: [PR] [FLINK-38975][runtime] Support application recovery [flink] via GitHub
• 2026/03/05 [jira] [Updated] (FLINK-38975) Re-execute applications after HA recovery in session mode ASF GitHub Bot (Jira)
• 2026/03/05 [PR] [FLINK-38975][runtime] Support application recovery [flink] via GitHub
• 2026/03/05 [jira] [Updated] (FLINK-39204) fluss yaml sink support add column at last ASF GitHub Bot (Jira)
• 2026/03/05 [PR] [FLINK-39204] Fluss yaml sink support add column at last. [flink-cdc] via GitHub
• 2026/03/05 Re: [PR] [FLINK-38096] AsyncSinkWriter may hang when configured with a custom rate limiting strategy [flink] via GitHub
• 2026/03/05 Re: [PR] [hotfix] Fix incorrect JavaDoc for session window assigners [flink] via GitHub
• 2026/03/05 [jira] [Commented] (FLINK-39220) Add tests for ConditionsUtils Harshit Gupta (Jira)
• 2026/03/05 [jira] [Created] (FLINK-39220) Add tests for ConditionsUtils Harshit Gupta (Jira)
• 2026/03/05 [jira] [Closed] (FLINK-39173) Support application-level blob storage Zhu Zhu (Jira)
• 2026/03/05 Re: [PR] [FLINK-39173][runtime] Support application-level blob storage [flink] via GitHub
• 2026/03/05 [PR] [MINOR] Update starrocks.md [flink-cdc] via GitHub
• 2026/03/05 [jira] [Closed] (FLINK-39205) fluss yaml sink support array/map/row Hongshun Wang (Jira)
• 2026/03/05 [jira] [Commented] (FLINK-39122) Decimals with incorrect precision lead to null value in PTF Rion Williams (Jira)
• 2026/03/05 Re: [PR] [FLINK-38160][starrocks] Add support for BINARY and VARBINARY types in StarRocks connector [flink-cdc] via GitHub
• 2026/03/05 Re: [PR] [FLINK-39195][Table SQL/API] ObjectPath should implement Comparable [flink] via GitHub
• 2026/03/05 Re: [PR] [FLINK-39195][Table SQL/API] ObjectPath should implement Comparable [flink] via GitHub
• 2026/03/05 Re: [PR] [FLINK-39195][Table SQL/API] ObjectPath should implement Comparable [flink] via GitHub
• 2026/03/05 Re: [PR] [FLINK-39015][table] Fix key extractor for multi join. Change GenericRowData to BinaryRowData [flink] via GitHub
• 2026/03/05 Re: [PR] [Feature][Java] Add OpenAI Responses API integration [flink-agents] via GitHub
• 2026/03/05 [jira] [Updated] (FLINK-39219) Support lineage extraction for DataStreamscan/sink providers Jaskaran Singh Kukreja (Jira)
• 2026/03/05 [jira] [Commented] (FLINK-39219) Support lineage extraction for DataStreamscan/sink providers Jaskaran Singh Kukreja (Jira)
• 2026/03/05 [jira] [Created] (FLINK-39219) Support lineage extraction for DataStreamscan/sink providers Jaskaran Singh Kukreja (Jira)
• 2026/03/05 [jira] [Updated] (FLINK-38726) Bump Fluss version to 0.9.0-incubating Leonard Xu (Jira)
• 2026/03/05 [jira] [Resolved] (FLINK-38726) Bump Fluss version to 0.9.0-incubating Leonard Xu (Jira)
• 2026/03/05 Re: [PR] [FLINK-38726][fluss] Bump Fluss version to 0.9.0-incubating [flink-cdc] via GitHub
• 2026/03/05 Re: [PR] [FLINK-39015][table] Fix key extractor for multi join. Change GenericRowData to BinaryRowData [flink] via GitHub
• 2026/03/05 Re: [PR] [FLINK-39178][table-planner] Support cascaded delta join in planner [flink] via GitHub
• 2026/03/05 Re: [PR] [FLINK-39178][table-planner] Support cascaded delta join in planner [flink] via GitHub
• 2026/03/05 [jira] [Closed] (FLINK-38974) Handle jobs in running applications during HA recovery Zhu Zhu (Jira)
• 2026/03/05 Re: [PR] [FLINK-38974][runtime] Handle jobs in running applications during HA recovery [flink] via GitHub
• 2026/03/05 Re: [PR] [FLINK-37837][core] Always add create.table to include.schema.changes option [flink-cdc] via GitHub
• 2026/03/05 [jira] [Closed] (FLINK-39150) Join operator crashes jobs when using custom types or custom type serializers Zhu Zhu (Jira)
• 2026/03/05 Re: [PR] [BP-2.2][FLINK-39150][runtime] Fix join operator crashes jobs when using custom types or custom type serializers [flink] via GitHub
• 2026/03/05 Re: [PR] [FLINK-38980][table] Migrate RemoveRedundantLocalSortAggRule to java [flink] via GitHub
• 2026/03/05 [jira] [Comment Edited] (FLINK-39150) Join operator crashes jobs when using custom types or custom type serializers Lei Yang (Jira)
• 2026/03/05 [jira] [Commented] (FLINK-39150) Join operator crashes jobs when using custom types or custom type serializers Lei Yang (Jira)
• 2026/03/05 Re: [PR] [FLINK-38822] Extend URL_DECODE with optional recursive decoding [flink] via GitHub
• 2026/03/05 Re: [PR] [FLINK-38822] Extend URL_DECODE with optional recursive decoding [flink] via GitHub
• 2026/03/05 Re: [PR] Include Kafka record metadata in deserialization error message [flink-connector-kafka] via GitHub
• 2026/03/05 [PR] Include Kafka record metadata in deserialization error message [flink-connector-kafka] via GitHub
• 2026/03/05 Re: [PR] Include Kafka record metadata in deserialization error message [flink-connector-kafka] via GitHub
• 2026/03/05 [jira] [Resolved] (FLINK-38981) Migrate BatchPhysicalSortMergeJoinRule Sergey Nuyanzin (Jira)
• 2026/03/05 [jira] [Commented] (FLINK-38981) Migrate BatchPhysicalSortMergeJoinRule Sergey Nuyanzin (Jira)
• 2026/03/05 [jira] [Assigned] (FLINK-38981) Migrate BatchPhysicalSortMergeJoinRule Sergey Nuyanzin (Jira)
• 2026/03/05 Re: [PR] [FLINK-38981][table] Migrate BatchPhysicalSortMergeJoinRule to java [flink] via GitHub
• 2026/03/05 [jira] [Updated] (FLINK-39077) Calculation of table changes for MT with several non persisted columns might fail Sergey Nuyanzin (Jira)
• 2026/03/05 [jira] [Resolved] (FLINK-39077) Calculation of table changes for MT with several non persisted columns might fail Sergey Nuyanzin (Jira)
• 2026/03/05 [jira] [Commented] (FLINK-39077) Calculation of table changes for MT with several non persisted columns might fail Sergey Nuyanzin (Jira)
• 2026/03/05 [jira] [Updated] (FLINK-39077) Calculation of table changes for MT with several non persisted columns might fail Sergey Nuyanzin (Jira)
• 2026/03/05 Re: [PR] [FLINK-39077][table] Calculation of table changes for MT with several non persisted columns might fail [flink] via GitHub
• 2026/03/05 [jira] [Resolved] (FLINK-17224) Precision of TIME type does not work correctly Sergey Nuyanzin (Jira)
• 2026/03/05 [jira] [Commented] (FLINK-17224) Precision of TIME type does not work correctly Sergey Nuyanzin (Jira)
• 2026/03/05 Re: [PR] [FLINK-17224][table] Support precision of TIME type [flink] via GitHub
• 2026/03/05 [jira] [Comment Edited] (FLINK-21309) Metrics of JobManager and TaskManager overwrite each other in pushgateway Qinghui Xu (Jira)
• 2026/03/05 [jira] [Commented] (FLINK-21309) Metrics of JobManager and TaskManager overwrite each other in pushgateway Qinghui Xu (Jira)
• 2026/03/05 [jira] [Assigned] (FLINK-39218) Add CLI tool to manage lingering Kafka transactions Danny Cranmer (Jira)
• 2026/03/05 [jira] [Comment Edited] (FLINK-21309) Metrics of JobManager and TaskManager overwrite each other in pushgateway Qinghui Xu (Jira)
• 2026/03/05 [jira] [Comment Edited] (FLINK-21309) Metrics of JobManager and TaskManager overwrite each other in pushgateway Qinghui Xu (Jira)
• 2026/03/05 [jira] [Commented] (FLINK-21309) Metrics of JobManager and TaskManager overwrite each other in pushgateway Qinghui Xu (Jira)
• 2026/03/05 [jira] [Created] (FLINK-39218) Add CLI tool to manage lingering Kafka transactions Aleksandr Savonin (Jira)
• 2026/03/05 Re: [PR] [FLINK-39202][table] Add new SimplifyCoalesceWithEquiJoinConditionRule [flink] via GitHub
• 2026/03/05 Re: [PR] [FLINK-39202][table] Add new SimplifyCoalesceWithEquiJoinConditionRule [flink] via GitHub
• 2026/03/05 Re: [PR] [FLINK-39202][table] Add new SimplifyCoalesceWithEquiJoinConditionRule [flink] via GitHub
• 2026/03/05 Re: [PR] [FLINK-39202][table] Add new SimplifyCoalesceWithEquiJoinConditionRule [flink] via GitHub
• 2026/03/05 [jira] [Updated] (FLINK-39165) Concurrent FlinkDeployment and FlinkSessionJob upgrades lead to savepoint failure and state loss ASF GitHub Bot (Jira)
• 2026/03/05 Re: [PR] [FLINK-39165] Prevent concurrent FlinkSessionJob / FlinkDeployment update [flink-kubernetes-operator] via GitHub
• 2026/03/05 Re: [PR] [FLINK-39202][table] Add new SimplifyCoalesceWithEquiJoinConditionRule [flink] via GitHub
• 2026/03/05 Re: [PR] [FLINK-39202][table] Add new SimplifyCoalesceWithEquiJoinConditionRule [flink] via GitHub
• 2026/03/05 Re: [PR] [FLINK-39202][table] Add new SimplifyCoalesceWithEquiJoinConditionRule [flink] via GitHub
• 2026/03/05 Re: [PR] [FLINK-39202][table] Add new SimplifyCoalesceWithEquiJoinConditionRule [flink] via GitHub
• 2026/03/05 Re: [PR] [FLINK-39202][table] Add new SimplifyCoalesceWithEquiJoinConditionRule [flink] via GitHub
• 2026/03/05 Re: [PR] [FLINK-39202][table] Add new SimplifyCoalesceWithEquiJoinConditionRule [flink] via GitHub
• 2026/03/05 Re: [PR] [FLINK-39202][table] Add new SimplifyCoalesceWithEquiJoinConditionRule [flink] via GitHub
• 2026/03/05 Re: [PR] [FLINK-39202][table] Add new SimplifyCoalesceWithEquiJoinConditionRule [flink] via GitHub
• 2026/03/05 Re: [PR] Add unit tests for ConditionsUtils [flink-kubernetes-operator] via GitHub
• 2026/03/05 Re: [PR] Update CI for Flink Connector Parent POM 2.0 compatibility [flink-connector-shared-utils] via GitHub
• 2026/03/05 Re: [PR] Update CI for Flink Connector Parent POM 2.0 compatibility [flink-connector-shared-utils] via GitHub
• 2026/03/05 [jira] [Closed] (FLINK-39182) Fix the flaky test class ExecutionGraphRestartTest Yuepeng Pan (Jira)
• 2026/03/05 Re: [PR] [FLINK-39182][runtime/test] Fix the flaky test class ExecutionGraphRestartTest [flink] via GitHub
• 2026/03/05 [jira] [Commented] (FLINK-38850) Support PostgreSQL uuid type Yuepeng Pan (Jira)
• 2026/03/05 Re: [PR] [FLINK-39178][table-planner] Support cascaded delta join in planner [flink] via GitHub
• 2026/03/05 Re: [PR] [FLINK-38850] Support PostgreSQL uuid type [flink-connector-jdbc] via GitHub
• 2026/03/05 Re: [PR] [FLINK-38850] Support PostgreSQL uuid type [flink-connector-jdbc] via GitHub
• 2026/03/05 Re: [PR] [FLINK-39178][table-planner] Support cascaded delta join in planner [flink] via GitHub
• 2026/03/05 Re: [PR] [FLINK-39178][table-planner] Support cascaded delta join in planner [flink] via GitHub
• 2026/03/05 [jira] [Resolved] (FLINK-39199) CREATE OR ALTER AMTERIALIZED TABLE doesn't support table options changes Sergey Nuyanzin (Jira)
• 2026/03/05 Re: [PR] [FLINK-39199][table] CREATE OR ALTER MATERIALIZED TABLE doesn't support table options changes [flink] via GitHub
• 2026/03/05 [jira] [Commented] (FLINK-39199) CREATE OR ALTER AMTERIALIZED TABLE doesn't support table options changes Sergey Nuyanzin (Jira)
• 2026/03/05 Re: [PR] FLINK-38334: Fix MySQL CDC source stuck in INITIAL_ASSIGNING [flink-cdc] via GitHub
• 2026/03/05 Re: [PR] [FLINK-39042][webui] Make watermark timestamps timezone-aware and configurable [flink] via GitHub
• 2026/03/05 Re: [PR] [Feature][Java] Add OpenAI Responses API integration [flink-agents] via GitHub
• 2026/03/05 Re: [PR] [FLINK-38825] Introduce AsyncBatchFunction and AsyncBatchWaitOperator [flink] via GitHub
• 2026/03/05 Re: [PR] [Feature][Java] Add OpenAI Responses API integration [flink-agents] via GitHub
• 2026/03/05 Re: [PR] [FLINK-38825] Add time-based batch triggering for AsyncBatchWaitOperator [flink] via GitHub
• 2026/03/05 [jira] [Updated] (FLINK-38160) StarRocks Pipeline connector supports TIME/BINARY/VARBINARY type mapping ASF GitHub Bot (Jira)
• 2026/03/05 [PR] [FLINK-38160][starrocks] Add support for BINARY and VARBINARY types in StarRocks connector [flink-cdc] via GitHub
• 2026/03/05 [PR] Add unit tests for ConditionsUtils [flink-kubernetes-operator] via GitHub
• 2026/03/05 Re: [PR] [FLINK-38729] Add support for Flink 2.2.0 [flink-cdc] via GitHub
• 2026/03/05 Re: [PR] [infra] Deduplicate common jar dependency to reduce wheel size [flink-agents] via GitHub
• 2026/03/05 Re: [PR] [FLINK-38814][Connector/Kinesis] Kinesis Source in EFO - Fix idle consumer on subscription failure [flink-connector-aws] via GitHub
• 2026/03/05 Re: [PR] [FLINK-38814][Connector/Kinesis] Kinesis Source in EFO - Fix idle consumer on subscription failure [flink-connector-aws] via GitHub
• 2026/03/05 Re: [PR] [FLINK-38814][Connector/Kinesis] Kinesis Source in EFO - Fix idle consumer on subscription failure [flink-connector-aws] via GitHub
• 2026/03/05 Re: [PR] [FLINK-38814][Connector/Kinesis] Kinesis Source in EFO - Fix idle consumer on subscription failure [flink-connector-aws] via GitHub
• 2026/03/05 Re: [PR] [FLINK-38814][Connector/Kinesis] Kinesis Source in EFO - Fix idle consumer on subscription failure [flink-connector-aws] via GitHub
• 2026/03/05 Re: [PR] [FLINK-38814][Connector/Kinesis] Kinesis Source in EFO - Fix idle consumer on subscription failure [flink-connector-aws] via GitHub
• 2026/03/05 Re: [PR] [FLINK-38814][Connector/Kinesis] Kinesis Source in EFO - Fix idle consumer on subscription failure [flink-connector-aws] via GitHub
• 2026/03/05 [jira] [Created] (FLINK-39217) CompactCoordinator throws FileNotFoundException during snapshotState due to race condition with StreamWriter liu (Jira)
• 2026/03/05 [jira] [Updated] (FLINK-39200) Skip deserialization of unsubscribed tables in MySql CDC binary log client ASF GitHub Bot (Jira)
• 2026/03/05 [PR] [FLINK-39200][mysql] Skip insert/update/delete binlog deserialization of unsubscribed tables in MySql CDC binary log client. [flink-cdc] via GitHub
• 2026/03/05 Re: [PR] [FLINK-39182][runtime/test] Fix the flaky test class ExecutionGraphRestartTest [flink] via GitHub
• 2026/03/05 Re: [PR] [FLINK-39182][runtime/test] Fix the flaky test class ExecutionGraphRestartTest [flink] via GitHub
• 2026/03/05 [PR] [FLINK-39182][runtime/test] Fix the flaky test class ExecutionGraphRestartTest [flink] via GitHub
• 2026/03/05 Re: [PR] [FLINK-17224][table] Support precision of TIME type [flink] via GitHub
• 2026/03/05 Re: [PR] [FLINK-17224][table] Support precision of TIME type [flink] via GitHub
• 2026/03/05 Re: [PR] [FLINK-38244][hotfix] Fix the full snapshot phase, the field case is adjusted based on isTableIdCaseInsensitive [flink-cdc] via GitHub
• 2026/03/05 Re: [PR] [FLINK-17224][table] Support precision of TIME type [flink] via GitHub
• 2026/03/05 Re: [PR] [FLINK-17224][table] Support precision of TIME type [flink] via GitHub
• 2026/03/05 Re: [PR] [FLINK-39202][table] Add new SimplifyCoalesceWithEquiJoinConditionRule [flink] via GitHub
• 2026/03/05 Re: [PR] [FLINK-39202][table] Add new SimplifyCoalesceWithEquiJoinConditionRule [flink] via GitHub
• 2026/03/05 Re: [PR] [FLINK-39202][table] Add new SimplifyCoalesceWithEquiJoinConditionRule [flink] via GitHub
• 2026/03/05 Re: [PR] [FLINK-37586][udf] Add support for options in user-defined functions and update related documentation [flink-cdc] via GitHub
• 2026/03/05 Re: [PR] [BP-2.2][FLINK-39150][runtime] Fix join operator crashes jobs when using custom types or custom type serializers [flink] via GitHub
• 2026/03/05 Re: [PR] [FLINK-39015][table] Fix key extractor for multi join. Change GenericRowData to BinaryRowData [flink] via GitHub
• 2026/03/05 [jira] [Commented] (FLINK-38196) IndexOutOfBoundsException when processing PostgreSQL tables with numeric(0) fields in Flink CDC Leonard Xu (Jira)
• 2026/03/05 [PR] [BP-2.2][FLINK-39150][runtime] Fix join operator crashes jobs when using custom types or custom type serializers [flink] via GitHub
• 2026/03/05 [jira] [Commented] (FLINK-39150) Join operator crashes jobs when using custom types or custom type serializers Zhu Zhu (Jira)
• 2026/03/05 Re: [PR] [FLINK-39150][runtime] Fix join operator crashes jobs when using custom types or custom type serializers [flink] via GitHub
• 2026/03/05 Re: [PR] [Feature][Java] Add OpenAI Responses API integration [flink-agents] via GitHub
• 2026/03/05 Re: [PR] [FLINK-38857][Model] Add docs for Triton inference model [flink] via GitHub

• Earlier messages