issues  

Messages by Date

• 2026/03/19 Re: [PR] [FLINK-38839][runtime] Support semicolon delimiter for table-options [flink-cdc] via GitHub
• 2026/03/19 Re: [PR] [FLINK-36520] CDC Supports MySQL 8.x and above [flink-cdc] via GitHub
• 2026/03/19 Re: [I] [Bug] Flink Agents Java MCPServer#listPrompts crashes(NullPointer) when required field is missing in prompt arguments [flink-agents] via GitHub
• 2026/03/19 Re: [PR] [FLINK-39235] Allow constants to be merged into request body via configuration [flink-connector-http] via GitHub
• 2026/03/19 [jira] [Updated] (FLINK-39166) Add bucket level config parity Samrat Deb (Jira)
• 2026/03/19 Re: [PR] [FLINK-39119] Package Native S3 FileSystem in Distribution [flink] via GitHub
• 2026/03/19 Re: [PR] [FLINK-38139] Fix consecutive online schema change causes job failure. [flink-cdc] via GitHub
• 2026/03/19 Re: [PR] Feat job name config [flink-agents] via GitHub
• 2026/03/19 Re: [I] [Bug] Flink Agents Java MCPServer#listPrompts crashes(NullPointer) when required field is missing in prompt arguments [flink-agents] via GitHub
• 2026/03/19 Re: [PR] [FLINK-39259][table] Support TO_CHANGELOG built-in process table function (upsert stream, flat mode) [flink] via GitHub
• 2026/03/19 Re: [PR] [FLINK-39259][table] Support TO_CHANGELOG built-in process table function (upsert stream, flat mode) [flink] via GitHub
• 2026/03/19 Re: [PR] [FLINK-39259][table] Support TO_CHANGELOG built-in process table function (upsert stream, flat mode) [flink] via GitHub
• 2026/03/19 Re: [PR] [FLINK-39259][table] Support TO_CHANGELOG built-in process table function (upsert stream, flat mode) [flink] via GitHub
• 2026/03/19 [jira] [Updated] (FLINK-39119) Add flink-s3-fs-native as part of flink dist in /opt ASF GitHub Bot (Jira)
• 2026/03/19 Re: [PR] [FLINK-39119] Package Native S3 FileSystem in Distribution [flink] via GitHub
• 2026/03/19 Re: [PR] [FLINK-38975][runtime] Support application recovery [flink] via GitHub
• 2026/03/19 Re: [PR] [FLINK-39235] Allow constants to be merged into request body via configuration [flink-connector-http] via GitHub
• 2026/03/19 Re: [PR] [FLINK-38342][runtime] Support record rescale information. [flink] via GitHub
• 2026/03/19 [jira] [Commented] (FLINK-39119) Add flink-s3-fs-native as part of flink dist in /opt Samrat Deb (Jira)
• 2026/03/19 Re: [PR] [FLINK-38342][runtime] Support record rescale information. [flink] via GitHub
• 2026/03/19 [PR] [FLINK-38342][runtime] Support record rescale information. [flink] via GitHub
• 2026/03/19 [jira] [Updated] (FLINK-39119) Add flink-s3-fs-native as part of flink dist in /opt Samrat Deb (Jira)
• 2026/03/19 [jira] [Updated] (FLINK-39119) Add flink-s3-fs-native as part of flink dist in /opt Samrat Deb (Jira)
• 2026/03/19 [PR] Announce Flink Agents 0.2.1 [flink-web] via GitHub
• 2026/03/19 Re: [PR] [FLINK-38592] Package Native S3 FileSystem in Distribution [flink] via GitHub
• 2026/03/19 Re: [PR] [FLINK-38592] Package Native S3 FileSystem in Distribution [flink] via GitHub
• 2026/03/19 [PR] [FLINK-38592] Package Native S3 FileSystem in Distribution [flink] via GitHub
• 2026/03/19 [jira] [Commented] (FLINK-39268) Support Common Subexpression Elimination (CSE) in Calc Code Generation Liu (Jira)
• 2026/03/19 [jira] [Updated] (FLINK-39269) Keep doc for deprecated config option Qinghui Xu (Jira)
• 2026/03/19 [jira] [Created] (FLINK-39269) Keep doc for deprecated config option Qinghui Xu (Jira)
• 2026/03/19 Re: [PR] [FLINK-38988][Table SQL/API] Support INET_ATON and INET_NTOA functions for IP address conversion [flink] via GitHub
• 2026/03/19 [jira] [Updated] (FLINK-39207) MySql cdc connector could get stuck in backfill binlog reading after a failover within snapshot phase Cong Cheng (Jira)
• 2026/03/19 Re: [PR] [FLINK-38988][Table SQL/API] Support INET_ATON and INET_NTOA functions for IP address conversion [flink] via GitHub
• 2026/03/19 Re: [PR] [FLINK-38988][Table SQL/API] Support INET_ATON and INET_NTOA functions for IP address conversion [flink] via GitHub
• 2026/03/19 Re: [PR] [FLINK-21309][metrics] Add UUID as grouping key for prom pushgateway [flink] via GitHub
• 2026/03/19 Re: [PR] Rebuild website [flink-web] via GitHub
• 2026/03/19 Re: [PR] [FLINK-36947][Connectors/Kinesis] Fix issue where excessive GetRecords calls are made on idle source causing high CPU utilisation and throttling [flink-connector-aws] via GitHub
• 2026/03/19 Re: [PR] [FLINK-37203] Alter table comment or column comment [flink-cdc] via GitHub
• 2026/03/19 [jira] [Assigned] (FLINK-39183) Support BITMAP type in Calcite parser lincoln lee (Jira)
• 2026/03/19 [jira] [Updated] (FLINK-39183) Support BITMAP type in Calcite parser lincoln lee (Jira)
• 2026/03/19 [jira] [Closed] (FLINK-39183) Support BITMAP type in Calcite parser lincoln lee (Jira)
• 2026/03/19 [I] [Bug] In MCPServer#listPrompts, Flink Agents unconditionally passes arg.required() to new MCPPrompt.PromptArgument(...). Later Boolean unboxing triggers a NullPointerException: [flink-agents] via GitHub
• 2026/03/19 Re: [PR] [FLINK-36165][source-connector/mysql] Support capturing snapshot data with conditions [flink-cdc] via GitHub
• 2026/03/19 Re: [PR] [FLINK-39183][table] Support BITMAP type in Calcite parser [flink] via GitHub
• 2026/03/19 Re: [I] [Tech Debt] Fix GitHub Actions security by replacing the pull_request_target trigger in workflows [flink-agents] via GitHub
• 2026/03/19 Re: [PR] [infra] Use GHA workflow triggers to run pull request labeler workflow [flink-agents] via GitHub
• 2026/03/19 Re: [PR] [infra] Use GHA workflow triggers to run pull request labeler workflow [flink-agents] via GitHub
• 2026/03/19 Re: [PR] [infra] Use GHA workflow triggers to run pull request labeler workflow [flink-agents] via GitHub
• 2026/03/19 [jira] [Commented] (FLINK-38592) [Phase 1] Native Flink S3 FileSystem Gabor Somogyi (Jira)
• 2026/03/19 Re: [PR] [FLINK-38592] Initial Native Flink S3 FileSystem [flink] via GitHub
• 2026/03/19 Re: [PR] [FLINK-38139] Fix consecutive online schema change causes job failure. [flink-cdc] via GitHub
• 2026/03/19 Re: [PR] [FLINK-39207][mysql] Fix mysql cdc could get stuck in backfill binlog reading when reuse snapshot split reader [flink-cdc] via GitHub
• 2026/03/19 Re: [PR] [FLINK-39207][mysql] Fix mysql cdc could get stuck in backfill binlog reading when reuse snapshot split reader [flink-cdc] via GitHub
• 2026/03/19 [jira] [Commented] (FLINK-39268) Support Common Subexpression Elimination (CSE) in Calc Code Generation Timo Walther (Jira)
• 2026/03/19 Re: [PR] [hotfix] Fix mismatch version. [flink-agents] via GitHub
• 2026/03/19 Re: [PR] [FLINK-37837][core] Always add create.table to include.schema.changes option [flink-cdc] via GitHub
• 2026/03/19 Re: [PR] [FLINK-38139] Fix consecutive online schema change causes job failure. [flink-cdc] via GitHub
• 2026/03/19 Re: [I] [Tech Debt] Reduce size of flink-agents wheel [flink-agents] via GitHub
• 2026/03/19 [PR] [FLINK-38139] Fix consecutive online schema change causes job failure. [flink-cdc] via GitHub
• 2026/03/19 Re: [PR] [FLINK-39207][mysql] Fix mysql cdc could get stuck in backfill binlog reading when reuse snapshot split reader [flink-cdc] via GitHub
• 2026/03/19 Re: [PR] [Flink-38911][cdc connector mysql] mysql-cdc-connector datastream support scan.binlog.newly-added-table.enabled [flink-cdc] via GitHub
• 2026/03/19 Re: [PR] [FLINK-39259][table] Support TO_CHANGELOG built-in process table function (upsert stream, flat mode) [flink] via GitHub
• 2026/03/19 Re: [PR] [Flink-38911][cdc connector mysql] mysql-cdc-connector datastream support scan.binlog.newly-added-table.enabled [flink-cdc] via GitHub
• 2026/03/19 [PR] [Flink-38911][cdc connector mysql] mysql-cdc-connector datastream support scan.binlog.newly-added-table.enabled [flink-cdc] via GitHub
• 2026/03/19 Re: [PR] [FLINK-39244][table] Support precision 0-9 for TO_TIMESTAMP_LTZ function [flink] via GitHub
• 2026/03/19 Re: [PR] [FLINK-38815] Mask sensitive values in Pekko configuration logs [flink] via GitHub
• 2026/03/19 Re: [PR] [FLINK-38729] Add Flink2 support for Source/Pipeline connector. [flink-cdc] via GitHub
• 2026/03/19 [PR] [hotfix] Fix mismatch version. [flink-agents] via GitHub
• 2026/03/19 Re: [PR] [Flink-38911][cdc connector mysql] mysql-cdc-connector datastream support scan.binlog.newly-added-table.enabled [flink-cdc] via GitHub
• 2026/03/19 [PR] Move setLastReconciledSpec to after successful transition start [flink-kubernetes-operator] via GitHub
• 2026/03/19 [jira] [Resolved] (FLINK-39149) `gtid.new.channel.position=LATEST` Incorrectly Replays Pre-Checkpoint Transactions for Old Channels in Multi-Source Replication Yanquan Lv (Jira)
• 2026/03/19 Re: [PR] [FLINK-39149][mysql-cdc] Implement LATEST mode GTID merging to prevent replaying pre-checkpoint transactions with non-contiguous ranges [flink-cdc] via GitHub
• 2026/03/19 Re: [PR] [Flink-38911][cdc connector mysql] mysql-cdc-connector datastream support scan.binlog.newly-added-table.enabled [flink-cdc] via GitHub
• 2026/03/18 Re: [PR] [FLINK-38828][cdc-common][cdc-runtime] Handle schema evolution upon projection updates via SchemaCoordinator [flink-cdc] via GitHub
• 2026/03/18 Re: [PR] [Flink-38911][cdc connector mysql] mysql-cdc-connector datastream support scan.binlog.newly-added-table.enabled [flink-cdc] via GitHub
• 2026/03/18 Re: [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/18 Re: [PR] [Flink-38911][cdc connector mysql] mysql-cdc-connector datastream support scan.binlog.newly-added-table.enabled [flink-cdc] via GitHub
• 2026/03/18 Re: [PR] [Flink-38911][cdc connector mysql] mysql-cdc-connector datastream support scan.binlog.newly-added-table.enabled [flink-cdc] via GitHub
• 2026/03/18 Re: [PR] [Flink-38911][cdc connector mysql] mysql-cdc-connector datastream support scan.binlog.newly-added-table.enabled [flink-cdc] via GitHub
• 2026/03/18 Re: [PR] [Flink-38911][cdc connector mysql] mysql-cdc-connector datastream support scan.binlog.newly-added-table.enabled [flink-cdc] via GitHub
• 2026/03/18 Re: [PR] [infra] Use GHA workflow triggers to run pull request labeler workflow [flink-agents] via GitHub
• 2026/03/18 Re: [PR] Bump js-yaml from 4.1.0 to 4.1.1 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/03/18 Re: [PR] Bump js-yaml from 4.1.0 to 4.1.1 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/03/18 Re: [PR] Bump js-yaml from 4.1.0 to 4.1.1 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/03/18 [PR] Clear stale savepointTriggerId on B/G transition abort [flink-kubernetes-operator] via GitHub
• 2026/03/18 Re: [PR] [FLINK-39234][tests] Wait for topic intialization in KafkaWriterTestBase based tests [flink-connector-kafka] via GitHub
• 2026/03/18 Re: [PR] [FLINK-39080] Introduce apache-rat check [flink-connector-kafka] via GitHub
• 2026/03/18 [PR] [infra] Use GHA workflow triggers to run pull request labeler workflow [flink-agents] via GitHub
• 2026/03/18 [PR] [infra] Use GHA workflow triggers to run pull request labeler workflow [flink-agents] via GitHub
• 2026/03/18 Re: [PR] [FLINK-38218] Fix MySQL CDC binlog split metadata split transmission [flink-cdc] via GitHub
• 2026/03/18 Re: [PR] [FLINK-39245][Iceberg] Add AWS Glue Catalog support for Iceberg pipeline connector [flink-cdc] via GitHub
• 2026/03/18 Re: [PR] [infra] Update the script for sdist release [flink-agents] via GitHub
• 2026/03/18 Re: [PR] [infra] Download JARs from Maven Central during pip install [flink-agents] via GitHub
• 2026/03/18 Re: [PR] [infra] Update the script for sdist release [flink-agents] via GitHub
• 2026/03/18 Re: [PR] [FLINK-36947][Connectors/Kinesis] Fix issue where excessive GetRecords calls are made on idle source causing high CPU utilisation and throttling [flink-connector-aws] via GitHub
• 2026/03/18 Re: [PR] [FLINK-38729] Add Flink2 support for Source/Pipeline connector. [flink-cdc] via GitHub
• 2026/03/18 Re: [PR] [FLINK-38815] Mask sensitive values in Pekko configuration logs [flink] via GitHub
• 2026/03/18 Re: [PR] [FLINK-38815] Mask sensitive values in Pekko configuration logs [flink] via GitHub
• 2026/03/18 Re: [PR] [FLINK-38988][Table SQL/API] Support INET_ATON and INET_NTOA functions for IP address conversion [flink] via GitHub
• 2026/03/18 Re: [PR] [FLINK-38988][Table SQL/API] Support INET_ATON and INET_NTOA functions for IP address conversion [flink] via GitHub
• 2026/03/18 Re: [PR] [FLINK-38704][metrics] Fix MetricConfig.getString() to handle numeric values [flink] via GitHub
• 2026/03/18 Re: [PR] [FLINK-38988][Table SQL/API] Support INET_ATON and INET_NTOA functions for IP address conversion [flink] via GitHub
• 2026/03/18 Re: [PR] [infra] Update the script for sdist release [flink-agents] via GitHub
• 2026/03/18 [PR] [infra] Update the script for sdist release [flink-agents] via GitHub
• 2026/03/18 [jira] [Created] (FLINK-39268) Support Common Subexpression Elimination (CSE) in Calc Code Generation Liu (Jira)
• 2026/03/18 Re: [PR] [FLINK-39149][mysql-cdc] Implement LATEST mode GTID merging to prevent replaying pre-checkpoint transactions with non-contiguous ranges [flink-cdc] via GitHub
• 2026/03/18 Re: [PR] [FLINK-38959][postgres] Update split state's table schemas info and infer schema change event based on pgoutput plugin's relation message. [flink-cdc] via GitHub
• 2026/03/18 Re: [PR] [FLINK-39071][oracle-cdc] Fix Oracle pipeline connector wrong field case [flink-cdc] via GitHub
• 2026/03/18 Re: [PR] [FLINK-39071][oracle-cdc] Fix Oracle pipeline connector wrong field case [flink-cdc] via GitHub
• 2026/03/18 Re: [PR] [FLINK-38959][postgres] Update split state's table schemas info and infer schema change event based on pgoutput plugin's relation message. [flink-cdc] via GitHub
• 2026/03/18 Re: [D] Flink Agents Release Process [flink-agents] via GitHub
• 2026/03/18 Re: [PR] [FLINK-39195][Table SQL/API] ObjectPath should implement Comparable [flink] via GitHub
• 2026/03/18 [jira] [Commented] (FLINK-39266) Support metadata column in sql create model ddl Cong Cheng (Jira)
• 2026/03/18 Re: [PR] [FLINK-36520] CDC Supports MySQL 8.x and above [flink-cdc] via GitHub
• 2026/03/18 Re: [PR] [FLINK-39021][Deployment/Kubernetes] Support native PersistentVolumeClaim (PVC) mounting for Kubernetes deployments [flink] via GitHub
• 2026/03/18 Re: [PR] [FLINK-39065][Formats (JSON, Avro, Parquet, ORC, SequenceFile)] Support additional CsvParser.Feature options for CSV format deserialization [flink] via GitHub
• 2026/03/18 Re: [PR] [FLINK-38729] Add Flink2 support for Source/Pipeline connector. [flink-cdc] via GitHub
• 2026/03/18 Re: [PR] [FLINK-39245][Iceberg] Add AWS Glue Catalog support for Iceberg pipeline connector [flink-cdc] via GitHub
• 2026/03/18 Re: [PR] [FLINK-38959][pipeline-connector][postgres]Added support for schema change in the postgres pipeline connector [flink-cdc] via GitHub
• 2026/03/18 [jira] [Updated] (FLINK-39267) Support dynamically updating checkpoint configuration at runtime via REST API Liu (Jira)
• 2026/03/18 Re: [PR] [infra] Use GHA workflow triggers to run pull request labeler workflow [flink-agents] via GitHub
• 2026/03/18 Re: [PR] [FLINK-38959][postgres] Update split state's table schemas info and infer schema change event based on pgoutput plugin's relation message. [flink-cdc] via GitHub
• 2026/03/18 Re: [PR] [FLINK-38959][postgres] Update split state's table schemas info and infer schema change event based on pgoutput plugin's relation message. [flink-cdc] via GitHub
• 2026/03/18 Re: [PR] [FLINK-38959][postgres] Update split state's table schemas info and infer schema change event based on pgoutput plugin's relation message. [flink-cdc] via GitHub
• 2026/03/18 [jira] [Created] (FLINK-39267) Support dynamically updating checkpoint configuration at runtime via REST API Liu (Jira)
• 2026/03/18 Re: [PR] [FLINK-38959][postgres] Update split state's table schemas info and infer schema change event based on pgoutput plugin's relation message. [flink-cdc] via GitHub
• 2026/03/18 Re: [PR] [FLINK-39252][pipeline-connector/sqlserver] Add SQL Server pipeline connector [flink-cdc] via GitHub
• 2026/03/18 Re: [PR] [FLINK-39252][pipeline-connector/sqlserver] Add SQL Server pipeline connector [flink-cdc] via GitHub
• 2026/03/18 Re: [PR] [FLINK-38218] Fix MySQL CDC binlog split metadata split transmission [flink-cdc] via GitHub
• 2026/03/18 Re: [PR] [FLINK-39252][pipeline-connector/sqlserver] Add SQL Server pipeline connector [flink-cdc] via GitHub
• 2026/03/18 Re: [PR] [runtime] Support async execution for cross language resources. [flink-agents] via GitHub
• 2026/03/18 Re: [PR] [FLINK-38218] Fix MySQL CDC binlog split metadata split transmission [flink-cdc] via GitHub
• 2026/03/18 Re: [PR] [FLINK-38218] Fix MySQL CDC binlog split metadata split transmission [flink-cdc] via GitHub
• 2026/03/18 Re: [PR] [FLINK-38139] Fix consecutive online schema change causes job failure. [flink-cdc] via GitHub
• 2026/03/18 Re: [PR] [FLINK-38139] Fix consecutive online schema change causes job failure. [flink-cdc] via GitHub
• 2026/03/18 Re: [PR] [FLINK-38822] Introduce URL_DECODE_RECURSIVE function for recursive URL decoding [flink] via GitHub
• 2026/03/18 [jira] [Commented] (FLINK-38815) The debug log will print the sensitive information of data security cookie certification in task manager and jobmanager VISHAL B (Jira)
• 2026/03/18 Re: [PR] [FLINK-38815] Mask sensitive values in Pekko configuration logs [flink] via GitHub
• 2026/03/18 [jira] [Updated] (FLINK-38815) The debug log will print the sensitive information of data security cookie certification in task manager and jobmanager ASF GitHub Bot (Jira)
• 2026/03/18 [PR] [FLINK-38815] Mask sensitive values in Pekko configuration logs [flink] via GitHub
• 2026/03/18 Re: [PR] [FLINK-39234][tests] Wait for topic intialization in KafkaWriterTestBase based tests [flink-connector-kafka] via GitHub
• 2026/03/18 [jira] [Updated] (FLINK-39125) Support injective casts from BINARY/VARBINARY to CHAR/VARCHAR for upsert key preservation Gustavo de Morais (Jira)
• 2026/03/18 Re: [PR] [FLINK-38930][checkpoint] Filtering record before processing without spilling strategy [flink] via GitHub
• 2026/03/18 [PR] [hotfix][docs] Restore target.utilization.boundary in configuration docs [flink-kubernetes-operator] via GitHub
• 2026/03/18 Re: [PR] [FLINK-39244][table] Support precision 0-9 for TO_TIMESTAMP_LTZ function [flink] via GitHub
• 2026/03/18 Re: [PR] [FLINK-38541][checkpoint] Introducing config option: execution.checkpointing.unaligned.during-recovery.enabled [flink] via GitHub
• 2026/03/18 [jira] [Updated] (FLINK-38930) Filtering record before processing without spilling strategy ASF GitHub Bot (Jira)
• 2026/03/18 [PR] [FLINK-38930][checkpoint] Filtering record before processing without spilling strategy [flink] via GitHub
• 2026/03/18 [jira] [Updated] (FLINK-38541) Introducing config option: execution.checkpointing.unaligned.during-recovery.enabled ASF GitHub Bot (Jira)
• 2026/03/18 [PR] [FLINK-38541][checkpoint] Introducing config option: execution.checkpointing.unaligned.during-recovery.enabled [flink] via GitHub
• 2026/03/18 Re: [PR] [FLINK-38218] Fix MySQL CDC binlog split metadata split transmission [flink-cdc] via GitHub
• 2026/03/18 Re: [PR] [FLINK-37155] [Runtime/Coordination] Implementing FLIP-505 for Flink History Server scalability improvements to decouple local and remote storage [flink] via GitHub
• 2026/03/18 Re: [PR] [FLINK-39244][table] Support precision 0-9 for TO_TIMESTAMP_LTZ function [flink] via GitHub
• 2026/03/18 Re: [PR] [FLINK-39244][table] Support precision 0-9 for TO_TIMESTAMP_LTZ function [flink] via GitHub
• 2026/03/18 Re: [PR] [FLINK-38218] Fix MySQL CDC binlog split metadata split transmission [flink-cdc] via GitHub
• 2026/03/18 Re: [PR] [FLINK-38218] Fix MySQL CDC binlog split metadata split transmission [flink-cdc] via GitHub
• 2026/03/18 Re: [D] Community Sync - 2026 [flink-agents] via GitHub
• 2026/03/18 Re: [D] Community Sync - 2026 [flink-agents] via GitHub
• 2026/03/18 [jira] [Resolved] (FLINK-33634) Add Conditions to Flink CRD's Status field David Radley (Jira)
• 2026/03/18 [jira] [Updated] (FLINK-33634) Add Conditions to Flink CRD's Status field David Radley (Jira)
• 2026/03/18 [jira] [Assigned] (FLINK-33634) Add Conditions to Flink CRD's Status field David Radley (Jira)
• 2026/03/18 [jira] [Comment Edited] (FLINK-39124) [JUnit5 Migration] Migrate the JUnit5 for Module: flink-tests Yuepeng Pan (Jira)
• 2026/03/18 [jira] [Resolved] (FLINK-38704) Metrics reporter setup does not load Prometheus with correct configs/port Rui Fan (Jira)
• 2026/03/18 [jira] [Assigned] (FLINK-38704) Metrics reporter setup does not load Prometheus with correct configs/port Rui Fan (Jira)
• 2026/03/18 [jira] [Updated] (FLINK-39266) Support metadata column in sql create model ddl Cong Cheng (Jira)
• 2026/03/18 [jira] [Commented] (FLINK-39124) [JUnit5 Migration] Migrate the JUnit5 for Module: flink-tests Yuepeng Pan (Jira)
• 2026/03/18 [jira] [Created] (FLINK-39266) Support metadata column in sql create model ddl Cong Cheng (Jira)
• 2026/03/18 [jira] [Resolved] (FLINK-39209) Flink cdc doris connector throw exception when serializing time data type columns Yanquan Lv (Jira)
• 2026/03/18 [jira] [Updated] (FLINK-39265) [postgres-cdc] PostgreSQL CDC intermittently drops INSERT records after checkpoint recovery due to WalPositionLocator filtering Di Wu (Jira)
• 2026/03/18 [jira] [Created] (FLINK-39265) [postgres-cdc] PostgreSQL CDC intermittently drops INSERT records after checkpoint recovery due to WalPositionLocator filtering Di Wu (Jira)
• 2026/03/18 [jira] [Updated] (FLINK-38852) FLIP-556: Introduce BITMAP Data Type Dian Fu (Jira)
• 2026/03/18 [jira] [Commented] (FLINK-38587) docker entrypoint script cannot handle FLINK_PROPERTIES that include spaces Jira
• 2026/03/17 [jira] [Resolved] (FLINK-39230) CDC Pipeline transform should handle partially-applied filters on UPDATE events Yanquan Lv (Jira)
• 2026/03/17 [jira] [Assigned] (FLINK-39184) Introduce Bitmap type for DataStream API Dian Fu (Jira)
• 2026/03/17 [jira] [Created] (FLINK-39264) Add docs for application management Yi Zhang (Jira)
• 2026/03/17 [jira] [Commented] (FLINK-36753) Adaptive Scheduler actively triggers a Checkpoint Samrat Deb (Jira)
• 2026/03/17 [jira] [Commented] (FLINK-38545) Update Pulsar connector to Flink 1.20 Fabrizzio Chavez (Jira)
• 2026/03/17 [jira] [Resolved] (FLINK-39238) Support watermark alignment in flink-connector-kafka in dynamic Kafka source mode Bowen Li (Jira)
• 2026/03/17 [jira] [Commented] (FLINK-39238) Support watermark alignment in flink-connector-kafka in dynamic Kafka source mode Bowen Li (Jira)
• 2026/03/17 [jira] [Assigned] (FLINK-39238) Support watermark alignment in flink-connector-kafka in dynamic Kafka source mode Bowen Li (Jira)
• 2026/03/17 [jira] [Updated] (FLINK-38770) pipeline.jobvertex-parallelism-overrides ignored for StreamGraph in Application Mode Barak (Jira)
• 2026/03/17 [jira] [Closed] (FLINK-39138) Update Flink Connector Kafka to Flink Connector Parent POM 2.0 Ferenc Csaky (Jira)
• 2026/03/17 [jira] [Created] (FLINK-39263) Support custom codecs in MongoDB Sink Jacob Jona Fahlenkamp (Jira)
• 2026/03/17 [jira] [Created] (FLINK-39262) Support dynamic namespace selection in MongoDB Sink Jacob Jona Fahlenkamp (Jira)
• 2026/03/17 [jira] [Updated] (FLINK-39262) Support dynamic namespace selection in MongoDB Sink Jacob Jona Fahlenkamp (Jira)
• 2026/03/17 [jira] [Created] (FLINK-39261) Add FROM_CHANGELOG built-in process table function (4.1.3.1 upsert stream to upsert stream) Gustavo de Morais (Jira)
• 2026/03/17 [jira] [Updated] (FLINK-39259) Add TO_CHANGELOG built-in process table function (4.2.2.2 upsert/retract stream, flat mode) Gustavo de Morais (Jira)
• 2026/03/17 Re: [PR] [FLINK-38959][postgres] Update split state's table schemas info and infer schema change event based on pgoutput plugin's relation message. [flink-cdc] via GitHub
• 2026/03/17 Re: [PR] [FLINK-38959][postgres] Update split state's table schemas info and infer schema change event based on pgoutput plugin's relation message. [flink-cdc] via GitHub
• 2026/03/17 [jira] [Commented] (FLINK-39260) Support multi-compression format python files Dian Fu (Jira)
• 2026/03/17 [jira] [Assigned] (FLINK-39260) Support multi-compression format python files Dian Fu (Jira)
• 2026/03/17 Re: [PR] [FLINK-38959][postgres] Update split state's table schemas info and infer schema change event based on pgoutput plugin's relation message. [flink-cdc] via GitHub
• 2026/03/17 Re: [PR] [FLINK-38959][postgres] Update split state's table schemas info and infer schema change event based on pgoutput plugin's relation message. [flink-cdc] via GitHub
• 2026/03/17 Re: [PR] [FLINK-38959][postgres] Update split state's table schemas info and infer schema change event based on pgoutput plugin's relation message. [flink-cdc] via GitHub
• 2026/03/17 Re: [PR] [FLINK-38959][postgres] Update split state's table schemas info and infer schema change event based on pgoutput plugin's relation message. [flink-cdc] via GitHub
• 2026/03/17 Re: [PR] [FLINK-38959][postgres] Update split state's table schemas info and infer schema change event based on pgoutput plugin's relation message. [flink-cdc] via GitHub
• 2026/03/17 Re: [PR] [FLINK-38959][postgres] Update split state's table schemas info and infer schema change event based on pgoutput plugin's relation message. [flink-cdc] via GitHub
• 2026/03/17 [jira] [Commented] (FLINK-39260) Support multi-compression format python files raoraoxiong (Jira)
• 2026/03/17 Re: [PR] [FLINK-38831][route] The route configuration supports matching the first one [flink-cdc] via GitHub
• 2026/03/17 [jira] [Created] (FLINK-39260) Support multi-compression format python files raoraoxiong (Jira)

• Earlier messages
• Later messages