issues  

Messages by Date

• 2026/06/01 Re: [PR] [FLINK-35726][table] Honor @DataTypeHint on POJO fields in type conve… [flink] via GitHub
• 2026/06/01 Re: [PR] [FLINK-XXXXX][table] Add config option and Catalog API for table to materialized table conversion [flink] via GitHub
• 2026/06/01 [jira] [Commented] (FLINK-39810) [kinesis] Support upsert changelog streams in Kinesis SQL connector Francisco Morillo (Jira)
• 2026/06/01 Re: [PR] [FLINK-39637][state] Add filter pushdown support for savepoint connector [flink] via GitHub
• 2026/06/01 Re: [PR] [FLINK-39637][state] Add filter pushdown support for savepoint connector [flink] via GitHub
• 2026/06/01 [jira] [Updated] (FLINK-35726) Data Stream to Table API converts Map to RAW 'java.util.Map' ASF GitHub Bot (Jira)
• 2026/06/01 [PR] [FLINK-35726][table] Honor @DataTypeHint on POJO fields in type conve… [flink] via GitHub
• 2026/06/01 [PR] [FLINK-XXXXX][table] Add config option and Catalog API for table to materialized table conversion [flink] via GitHub
• 2026/06/01 Re: [PR] [FLINK-39812][table] Migrate `FlinkTypeFactory` to java [flink] via GitHub
• 2026/06/01 Re: [PR] [FLINK-39812][table] Migrate `FlinkTypeFactory` to java [flink] via GitHub
• 2026/06/01 Re: [PR] [FLINK-39799][table] Preserve user-typed query text for materialized table and view definitions [flink] via GitHub
• 2026/06/01 Re: [PR] [FLINK-39064][Table SQL / API] Add built-in REGEXP_SPLIT function to split string by regular expression pattern [flink] via GitHub
• 2026/06/01 Re: [PR] [FLINK-39064][Table SQL / API] Add built-in REGEXP_SPLIT function to split string by regular expression pattern [flink] via GitHub
• 2026/06/01 Re: [PR] [FLINK-39728] Fix pauseOrResumeSplits race with unassigned partitions [flink-connector-kafka] via GitHub
• 2026/06/01 Re: [PR] [FLINK-39258][table] Extend restore tests for TO_CHANGELOG and FROM_CHANGELOG [flink] via GitHub
• 2026/06/01 Re: [PR] [FLINK-39258][table] Extend restore tests for TO_CHANGELOG and FROM_CHANGELOG [flink] via GitHub
• 2026/06/01 [jira] [Commented] (FLINK-39810) [kinesis] Support upsert changelog streams in Kinesis SQL connector Francisco Morillo (Jira)
• 2026/06/01 Re: [PR] [FLINK-39136][filesystems] Bump google-cloud-storage to 2.68.0 in flink-gs-fs-hadoop [flink] via GitHub
• 2026/06/01 [jira] [Updated] (FLINK-39136) GS file system fails to retry on certain 503's due to old GCS lib dependency Martijn Visser (Jira)
• 2026/06/01 [jira] [Assigned] (FLINK-39136) GS file system fails to retry on certain 503's due to old GCS lib dependency Martijn Visser (Jira)
• 2026/06/01 Re: [PR] [FLINK-39799][table] Preserve user-typed query text for materialized table and view definitions [flink] via GitHub
• 2026/06/01 Re: [PR] [FLINK-39136] [flink-gs-fs-hadoop] bump com.google.cloud:google-cloud-storage from 2.29.1 to 2.62.1 [flink] via GitHub
• 2026/06/01 [PR] [FLINK-39136][filesystems] Bump google-cloud-storage to 2.68.0 in flink-gs-fs-hadoop [flink] via GitHub
• 2026/06/01 Re: [PR] Add Flink 2.3.0 release [flink-web] via GitHub
• 2026/06/01 Re: [PR] Add Flink 2.3.0 release [flink-web] via GitHub
• 2026/06/01 Re: [PR] [FLINK-39811][s3] Optionally Adjust s5cmd part size to fully utilize s5cmd workers pool during downloads [flink] via GitHub
• 2026/06/01 Re: [PR] [FLINK-39258][table] Extend restore tests for TO_CHANGELOG and FROM_CHANGELOG [flink] via GitHub
• 2026/06/01 Re: [PR] [FLINK-39258][table] Extend restore tests for TO_CHANGELOG and FROM_CHANGELOG [flink] via GitHub
• 2026/06/01 Re: [PR] [FLINK-39258][table] Extend restore tests for TO_CHANGELOG and FROM_CHANGELOG [flink] via GitHub
• 2026/06/01 Re: [PR] [FLINK-38450][iceberg] Fix duplicate records when schema change splits writes within a checkpoint [flink-cdc] via GitHub
• 2026/06/01 [PR] [FLINK-39811][s3] Optionally Adjust s5cmd part size to fully utilize s5cmd workers pool during downloads [flink] via GitHub
• 2026/06/01 [jira] [Updated] (FLINK-39811) S5cmd effective concurrency capped by static part size for small downloads ASF GitHub Bot (Jira)
• 2026/06/01 Re: [PR] [FLINK-36267][table] Fix SPLIT not preserving SMP characters when delimiter is empty [flink] via GitHub
• 2026/06/01 [jira] [Commented] (FLINK-39810) [kinesis] Support upsert changelog streams in Kinesis SQL connector Martijn Visser (Jira)
• 2026/06/01 Re: [PR] [FLINK-39110] Add CRT support in native-s3-fs [flink] via GitHub
• 2026/06/01 [jira] [Commented] (FLINK-39810) [kinesis] Support upsert changelog streams in Kinesis SQL connector Francisco Morillo (Jira)
• 2026/06/01 [jira] [Updated] (FLINK-39699) Kafka connector CI failed on the main branch Martijn Visser (Jira)
• 2026/06/01 [jira] [Commented] (FLINK-39699) Kafka connector CI failed on the main branch Martijn Visser (Jira)
• 2026/06/01 Re: [PR] [FLINK-39699][BP v4.0][tests] Stabilize flaky tests in KafkaSinkITCase and KafkaWriterFaultToleranceITCase [flink-connector-kafka] via GitHub
• 2026/06/01 [jira] [Commented] (FLINK-39810) [kinesis] Support upsert changelog streams in Kinesis SQL connector Martijn Visser (Jira)
• 2026/06/01 Re: [PR] [FLINK-39720][table] SubQueryDecorrelator produces incorrect plans for correlated EXISTS with HAVING on aggregate outputs [flink] via GitHub
• 2026/06/01 Re: [PR] [FLINK-39583][table-planner] Normalize Calcite correl variables for more effective sub-plan digest reuse [flink] via GitHub
• 2026/06/01 [jira] [Closed] (FLINK-38299) amend push github action to go against v1 snapshot david radley (Jira)
• 2026/06/01 [jira] [Assigned] (FLINK-38304) Re write README david radley (Jira)
• 2026/06/01 [jira] [Closed] (FLINK-38305) amend the prefix to not include gid and move to http david radley (Jira)
• 2026/06/01 [jira] [Assigned] (FLINK-38302) change the config to use Flink config parameter names and gid fallback keys david radley (Jira)
• 2026/06/01 [jira] [Assigned] (FLINK-38305) amend the prefix to not include gid and move to http david radley (Jira)
• 2026/06/01 [jira] [Closed] (FLINK-38304) Re write README david radley (Jira)
• 2026/06/01 [jira] [Closed] (FLINK-38303) default to use query-creator generic-json-url david radley (Jira)
• 2026/06/01 [jira] [Closed] (FLINK-38296) Do documentation david radley (Jira)
• 2026/06/01 [jira] [Assigned] (FLINK-38300) work out Flink v2 support (should work) david radley (Jira)
• 2026/06/01 [jira] [Closed] (FLINK-38298) Remove mockito dependancy so we do not need to exclude from banned checklist david radley (Jira)
• 2026/06/01 [jira] [Assigned] (FLINK-38298) Remove mockito dependancy so we do not need to exclude from banned checklist david radley (Jira)
• 2026/06/01 [jira] [Closed] (FLINK-38297) wiremock version is very old - migrate to a later level david radley (Jira)
• 2026/06/01 [jira] [Closed] (FLINK-38300) work out Flink v2 support (should work) david radley (Jira)
• 2026/06/01 [jira] [Assigned] (FLINK-38245) FLIP-532: Donate GetInData HTTP Connector to Flink david radley (Jira)
• 2026/06/01 [jira] [Closed] (FLINK-38295) Amend parent connector pom version to 1.1.0 david radley (Jira)
• 2026/06/01 Re: [PR] [FLINK-39583][table-planner] Normalize Calcite correl variables for more effective sub-plan digest reuse [flink] via GitHub
• 2026/06/01 Re: [PR] [FLINK-39812][table] Migrate `FlinkTypeFactory` to java [flink] via GitHub
• 2026/06/01 Re: [PR] [FLINK-39583][table-planner] Normalize Calcite correl variables for more effective sub-plan digest reuse [flink] via GitHub
• 2026/06/01 [PR] [FLINK-39699][tests] Stabilize flaky tests in KafkaSinkITCase and KafkaWriterFaultToleranceITCase [flink-connector-kafka] via GitHub
• 2026/06/01 Re: [PR] [FLINK-39740][table-runtime] Do not regress highestSqnAndSizeState on row replace in LinkedMultiSetState [flink] via GitHub
• 2026/06/01 Re: [PR] [FLINK-39740][table-runtime] Do not regress highestSqnAndSizeState on row replace in LinkedMultiSetState [flink] via GitHub
• 2026/06/01 Re: [PR] [FLINK-39418] Fix decimal truncation when precision / scale is over 19 [flink-cdc] via GitHub
• 2026/06/01 [PR] [FLINK-39810][Kinesis/Connector] Add lineage support to Kinesis Streams connector [flink-connector-aws] via GitHub
• 2026/06/01 Re: [PR] [ci][hotfix] Enable parallel execution for pipeline-e2e tests [flink-cdc] via GitHub
• 2026/06/01 Re: [PR] [FLINK-39621] Fix incremental-snapshot based sources may get stuck in binlog-backfill stage [flink-cdc] via GitHub
• 2026/06/01 [PR] [release-0.2][backport][api][plan][integrations] Record built-in chat token metrics outside the async call boundary (#712) [flink-agents] via GitHub
• 2026/06/01 [jira] [Created] (FLINK-39813) [Connectors/Kinesis] Add lineage support to Kinesis Streams connector Francisco Morillo (Jira)
• 2026/06/01 [jira] [Commented] (FLINK-39801) Skip serializing empty partitionKeys / orderKeys / orderDirections in TABLE_ARG_CALL compiled plan Sergey Nuyanzin (Jira)
• 2026/06/01 [jira] [Resolved] (FLINK-39801) Skip serializing empty partitionKeys / orderKeys / orderDirections in TABLE_ARG_CALL compiled plan Sergey Nuyanzin (Jira)
• 2026/06/01 Re: [PR] [FLINK-39801][table] Skip serializing empty partition/order keys for PTF table args [flink] via GitHub
• 2026/06/01 [jira] [Commented] (FLINK-39753) RocksDB ColumnFamilyOptions and LRUCache leak in Compactor Yuepeng Pan (Jira)
• 2026/06/01 Re: [PR] [BP-2.3][FLINK-39753][state/rocksdb] Close ColumnFamilyOptions from getDescriptor() in Compactor [flink] via GitHub
• 2026/06/01 Re: [PR] [FLINK-39711][runtime] Expose maxExceptions on exception message parameters [flink] via GitHub
• 2026/06/01 Re: [PR] [FLINK-36235][Stream] Ignore emitting null rowData when deserialized message fails [flink-connector-pulsar] via GitHub
• 2026/06/01 Re: [PR] [FLINK-39258][table] Extend restore tests for TO_CHANGELOG and FROM_CHANGELOG [flink] via GitHub
• 2026/06/01 Re: [PR] [FLINK-39812][table] Migrate `FlinkTypeFactory` to java [flink] via GitHub
• 2026/06/01 Re: [PR] [FLINK-38450][iceberg] Fix duplicate records when schema change splits writes within a checkpoint [flink-cdc] via GitHub
• 2026/06/01 Re: [PR] [FLINK-39582][postgres] Allow logical messages [flink-cdc] via GitHub
• 2026/06/01 Re: [PR] [api][plan][integrations] Record built-in chat token metrics outside the async call boundary [flink-agents] via GitHub
• 2026/06/01 [jira] [Commented] (FLINK-37351) Ensure writer and committer are colocated Arvind Kandpal (Jira)
• 2026/06/01 [jira] [Updated] (FLINK-39812) Migrate FlinkTypeFactory to java ASF GitHub Bot (Jira)
• 2026/06/01 [PR] [FLINK-39812][table] Migrate `FlinkTypeFactory` to java [flink] via GitHub
• 2026/06/01 Re: [PR] Add Flink 2.3.0 release [flink-web] via GitHub
• 2026/06/01 Re: [PR] Add Flink 2.3.0 release [flink-web] via GitHub
• 2026/06/01 [jira] [Created] (FLINK-39812) Migrate FlinkTypeFactory to java Sergey Nuyanzin (Jira)
• 2026/06/01 Re: [PR] [FLINK-39767][tests][JUnit5 migration] Module: flink-statebackend-forst [flink] via GitHub
• 2026/06/01 [jira] [Resolved] (FLINK-37422) Typo in streaming analytics zh document reswqa (Jira)
• 2026/06/01 [jira] [Assigned] (FLINK-37422) Typo in streaming analytics zh document reswqa (Jira)
• 2026/06/01 Re: [PR] [FLINK-39767][tests][JUnit5 migration] Module: flink-statebackend-forst [flink] via GitHub
• 2026/06/01 Re: [PR] [FLINK-37422][docs] Fix typos and translation alignment in streaming analytics zh document [flink] via GitHub
• 2026/06/01 Re: [PR] [FLINK-39767][tests][JUnit5 migration] Module: flink-statebackend-forst [flink] via GitHub
• 2026/06/01 [jira] [Updated] (FLINK-39811) S5cmd effective concurrency capped by static part size for small downloads Efrat Levitan (Jira)
• 2026/06/01 [jira] [Created] (FLINK-39811) S5cmd effective concurrency capped by static part size for small downloads Efrat Levitan (Jira)
• 2026/06/01 Re: [PR] [api][plan][integrations] Record built-in chat token metrics outside the async call boundary [flink-agents] via GitHub
• 2026/06/01 [jira] [Closed] (FLINK-39717) Document SET/RESET key handling for ALTER TABLE, CATALOG, MODEL and DATABASE Gustavo de Morais (Jira)
• 2026/06/01 Re: [PR] [Flink 39717][docs] Document SET/RESET key handling for ALTER TABLE, CATALOG, MODEL and DATABASE [flink] via GitHub
• 2026/06/01 [jira] [Assigned] (FLINK-39717) Document SET/RESET key handling for ALTER TABLE, CATALOG, MODEL and DATABASE Gustavo de Morais (Jira)
• 2026/06/01 Re: [PR] [BP-2.3][FLINK-39753][state/rocksdb] Close ColumnFamilyOptions from getDescriptor() in Compactor [flink] via GitHub
• 2026/06/01 [jira] [Updated] (FLINK-39810) [kinesis] Support upsert changelog streams in Kinesis SQL connector ASF GitHub Bot (Jira)
• 2026/06/01 [PR] [FLINK-39810][Connectors/kinesis] Support upsert changelog streams in Kinesis SQL connector [flink-connector-aws] via GitHub
• 2026/06/01 Re: [PR] [FLINK-39216][helm] Add PKCS12 profile option for webhook certificate [flink-kubernetes-operator] via GitHub
• 2026/06/01 [jira] [Created] (FLINK-39810) [kinesis] Support upsert changelog streams in Kinesis SQL connector Francisco Morillo (Jira)
• 2026/06/01 Re: [PR] 39443 debug [flink-benchmarks] via GitHub
• 2026/06/01 Re: [PR] [FLINK-39767][tests][JUnit5 migration] Module: flink-statebackend-forst [flink] via GitHub
• 2026/06/01 [jira] [Commented] (FLINK-39808) Tighten FlinkVersion.isSupported() to reject @Deprecated versions and restore the deprecate-and-raise-floor pattern Gyula Fora (Jira)
• 2026/06/01 [jira] [Commented] (FLINK-39715) [Table/Planner] IndexOutOfBoundsException in FlinkExpandConversionRule for ORDER BY followed by global aggregate in batch mode Arvind Kandpal (Jira)
• 2026/06/01 Re: [PR] [FLINK-37422][docs] Fix typos and translation alignment in streaming analytics zh document [flink] via GitHub
• 2026/06/01 [jira] [Commented] (FLINK-39791) Helm chart silently ignores defaultConfiguration.config.yaml; always mounts flink-conf.yaml from chart defaults Dennis-Mircea Ciupitu (Jira)
• 2026/06/01 [jira] [Commented] (FLINK-39786) closeForCommit() leaks orphan multipart uploads on upload failure Arvind Kandpal (Jira)
• 2026/06/01 [jira] [Commented] (FLINK-37502) Translate documentation for Disaggregated State Management into Chinese Arvind Kandpal (Jira)
• 2026/06/01 [jira] [Commented] (FLINK-39808) Tighten FlinkVersion.isSupported() to reject @Deprecated versions and restore the deprecate-and-raise-floor pattern Arvind Kandpal (Jira)
• 2026/06/01 [jira] [Commented] (FLINK-39808) Tighten FlinkVersion.isSupported() to reject @Deprecated versions and restore the deprecate-and-raise-floor pattern Dennis-Mircea Ciupitu (Jira)
• 2026/06/01 [jira] [Updated] (FLINK-39808) Tighten FlinkVersion.isSupported() to reject @Deprecated versions and restore the deprecate-and-raise-floor pattern ASF GitHub Bot (Jira)
• 2026/06/01 [PR] [FLINK-39808] Tighten FlinkVersion.isSupported() to reject @Deprecated versions and restore the deprecate-and-raise-floor pattern [flink-kubernetes-operator] via GitHub
• 2026/06/01 [jira] [Commented] (FLINK-39615) Translate documentation in changelog.md to chinese Arvind Kandpal (Jira)
• 2026/06/01 Re: [PR] Add Flink 2.3.0 release [flink-web] via GitHub
• 2026/06/01 [I] [Bug] AgentPlan resource getter is not thread-safe on release-0.2 [flink-agents] via GitHub
• 2026/06/01 Re: [PR] [FLINK-39059][models] Add unified inference metrics for model functions [flink] via GitHub
• 2026/06/01 Re: [PR] [FLINK-34610] Migrate `StreamPhysicalLimitRule` from Scala to Java [flink] via GitHub
• 2026/06/01 [jira] [Created] (FLINK-39809) Update flink-connector-parent to 2.0 for ElasticSearch connector reswqa (Jira)
• 2026/06/01 [jira] [Commented] (FLINK-39808) Tighten FlinkVersion.isSupported() to reject @Deprecated versions and restore the deprecate-and-raise-floor pattern Arvind Kandpal (Jira)
• 2026/06/01 [jira] [Resolved] (FLINK-39798) Add uber jar for es8 module reswqa (Jira)
• 2026/06/01 [jira] [Updated] (FLINK-39798) Add uber jar for es8 module reswqa (Jira)
• 2026/06/01 [I] [Bug] Python memory can persist Pemja-incompatible values and fail after state backend restore [flink-agents] via GitHub
• 2026/06/01 Re: [PR] [FLINK-39798] Introduce uber jar for flink-connector-elasticsearch8 module [flink-connector-elasticsearch] via GitHub
• 2026/06/01 Re: [PR] [feature][integration][java] Add built-in Google Gemini chat model integration [flink-agents] via GitHub
• 2026/06/01 Re: [PR] [FLINK-38450][iceberg] Fix duplicate records when schema change splits writes within a checkpoint [flink-cdc] via GitHub
• 2026/06/01 Re: [PR] [feature][integration][java] Add built-in Google Gemini chat model integration [flink-agents] via GitHub
• 2026/06/01 [jira] [Updated] (FLINK-39808) Tighten FlinkVersion.isSupported() to reject @Deprecated versions and restore the deprecate-and-raise-floor pattern Dennis-Mircea Ciupitu (Jira)
• 2026/06/01 Re: [PR] [FLINK-39798] Introduce uber jar for flink-connector-elasticsearch8 module [flink-connector-elasticsearch] via GitHub
• 2026/06/01 [jira] [Commented] (FLINK-39426) Flink 2.0 and Connector version compatibility issue Robert Metzger (Jira)
• 2026/06/01 [jira] [Updated] (FLINK-39808) Tighten FlinkVersion.isSupported() to reject @Deprecated versions and restore the deprecate-and-raise-floor pattern Dennis-Mircea Ciupitu (Jira)
• 2026/06/01 [jira] [Created] (FLINK-39808) Tighten `FlinkVersion.isSupported()` to reject `@Deprecated` versions and restore the deprecate-and-raise-floor pattern Dennis-Mircea Ciupitu (Jira)
• 2026/06/01 Re: [PR] [FLINK-39767][tests][JUnit5 migration] Module: flink-statebackend-forst [flink] via GitHub
• 2026/06/01 Re: [PR] [FLINK-39767][tests][JUnit5 migration] Module: flink-statebackend-forst [flink] via GitHub
• 2026/06/01 Re: [PR] [FLINK-39767][tests][JUnit5 migration] Module: flink-statebackend-forst [flink] via GitHub
• 2026/06/01 Re: [PR] [FLINK-39767][tests][JUnit5 migration] Module: flink-statebackend-forst [flink] via GitHub
• 2026/06/01 Re: [PR] [FLINK-39767][tests][JUnit5 migration] Module: flink-statebackend-forst [flink] via GitHub
• 2026/06/01 Re: [PR] [FLINK-39767][tests][JUnit5 migration] Module: flink-statebackend-forst [flink] via GitHub
• 2026/06/01 Re: [PR] [FLINK-39767][tests][JUnit5 migration] Module: flink-statebackend-forst [flink] via GitHub
• 2026/05/31 Re: [PR] [e2e] Add nightly e2e test for submitting examples to flink standalone cluster [flink-agents] via GitHub
• 2026/05/31 Re: [PR] [e2e] Add nightly e2e test for submitting examples to flink standalone cluster [flink-agents] via GitHub
• 2026/05/31 Re: [PR] Add Flink 2.3.0 release [flink-web] via GitHub
• 2026/05/31 Re: [I] [Tech Debt] Rename connection-layer chat() argument from "arguments" to "modelParams" for namin [flink-agents] via GitHub
• 2026/05/31 Re: [PR] [integrations][api] Rename connection-layer chat() argument to modelParams [flink-agents] via GitHub
• 2026/05/31 Re: [PR] [api][runtime][python] Expose short-term memory state TTL cleanup strategy as a config option [flink-agents] via GitHub
• 2026/05/31 [jira] [Commented] (FLINK-39743) Incorrect Expected Processing Rate Computation Devika Sudheer (Jira)
• 2026/05/31 [jira] [Commented] (FLINK-39426) Flink 2.0 and Connector version compatibility issue Paras Negi (Jira)
• 2026/05/31 [jira] (FLINK-39426) Flink 2.0 and Connector version compatibility issue Paras Negi (Jira)
• 2026/05/31 [jira] (FLINK-39426) Flink 2.0 and Connector version compatibility issue Paras Negi (Jira)
• 2026/05/31 [jira] [Updated] (FLINK-39807) [umbrella] FLIP-577: AI-Native Flink — Umbrella for Multimodal Data Processing Guowei Ma (Jira)
• 2026/05/31 [jira] [Updated] (FLINK-39807) [umbrella] FLIP-577: AI-Native Flink — Umbrella for Multimodal Data Processing Guowei Ma (Jira)
• 2026/05/31 [jira] [Updated] (FLINK-39807) [umbrella] FLIP-577: AI-Native Flink — Umbrella for Multimodal Data Processing Guowei Ma (Jira)
• 2026/05/31 [jira] [Assigned] (FLINK-39807) [umbrella] FLIP-577: AI-Native Flink — Umbrella for Multimodal Data Processing Guowei Ma (Jira)
• 2026/05/31 [jira] [Created] (FLINK-39807) [umbrella] FLIP-577: AI-Native Flink — Umbrella for Multimodal Data Processing Guowei Ma (Jira)
• 2026/05/31 Re: [PR] [FLINK-38450][iceberg] Fix duplicate records when schema change splits writes within a checkpoint [flink-cdc] via GitHub
• 2026/05/31 Re: [PR] [hotfix][docs] Fix code examples and minor issues in DataStream documentation [flink] via GitHub
• 2026/05/31 Re: [PR] [hotfix][docs] Fix code examples and minor issues in DataStream documentation [flink] via GitHub
• 2026/05/31 [jira] [Updated] (FLINK-39591) Bump actions v4 to v5 Yunfeng Zhou (Jira)
• 2026/05/31 [jira] [Updated] (FLINK-39672) Update doc about Java Records Yunfeng Zhou (Jira)
• 2026/05/31 [jira] [Updated] (FLINK-36609) Protobuf Format not support proto3 Yunfeng Zhou (Jira)
• 2026/05/31 [jira] [Updated] (FLINK-39136) GS file system fails to retry on certain 503's due to old GCS lib dependency Yunfeng Zhou (Jira)
• 2026/05/31 Re: [PR] [FLINK-38450][iceberg] Fix duplicate records when schema change splits writes within a checkpoint [flink-cdc] via GitHub
• 2026/05/31 [jira] [Commented] (FLINK-39136) GS file system fails to retry on certain 503's due to old GCS lib dependency Yunfeng Zhou (Jira)
• 2026/05/31 [jira] [Closed] (FLINK-36609) Protobuf Format not support proto3 Hongshun Wang (Jira)
• 2026/05/31 [jira] [Updated] (FLINK-37246) Delegation Token expire after enable delegation token framework Yunfeng Zhou (Jira)
• 2026/05/31 [jira] [Commented] (FLINK-37246) Delegation Token expire after enable delegation token framework Yunfeng Zhou (Jira)
• 2026/05/31 [jira] [Assigned] (FLINK-38450) flink-cdc sink to iceberg table record duplication Yanquan Lv (Jira)
• 2026/05/31 [jira] [Commented] (FLINK-36735) SupportsRowLevelUpdate gives sink only the values of required columns when specifying RowLevelUpdateInfo#requiredColumns Yunfeng Zhou (Jira)
• 2026/05/31 [jira] [Updated] (FLINK-36735) SupportsRowLevelUpdate gives sink only the values of required columns when specifying RowLevelUpdateInfo#requiredColumns Yunfeng Zhou (Jira)
• 2026/05/31 [jira] [Updated] (FLINK-36736) DynamicTableSink.Context#getTargetColumns should contains all the columns that sink function will receive Yunfeng Zhou (Jira)
• 2026/05/31 [jira] [Commented] (FLINK-36736) DynamicTableSink.Context#getTargetColumns should contains all the columns that sink function will receive Yunfeng Zhou (Jira)
• 2026/05/31 Re: [I] [Feature] Support Agent Skills [flink-agents] via GitHub
• 2026/05/31 Re: [I] [Feature] Import Wizard for Installation Setup [flink-agents] via GitHub
• 2026/05/31 Re: [I] [Feature] Add Amazon Bedrock integration for chat models and embedding models [flink-agents] via GitHub
• 2026/05/31 Re: [I] [Feature] Add Amazon OpenSearch and S3 Vectors vector store integrations [flink-agents] via GitHub
• 2026/05/31 Re: [PR] [FLINK-39753][state/rocksdb] Close ColumnFamilyOptions from getDescriptor() in Compactor (2.3 backport) [flink] via GitHub
• 2026/05/31 [PR] [test][runtime] Strengthen live-LLM e2e tests with structured tool-invocation assertions [flink-agents] via GitHub
• 2026/05/31 Re: [PR] [e2e] Add nightly e2e test for submitting examples to flink standalone cluster [flink-agents] via GitHub
• 2026/05/31 Re: [PR] [e2e] Add nightly e2e test for submitting examples to flink standalone cluster [flink-agents] via GitHub
• 2026/05/31 Re: [PR] [e2e] Add nightly e2e test for submitting examples to flink standalone cluster [flink-agents] via GitHub
• 2026/05/31 Re: [PR] [e2e] Add nightly e2e test for submitting examples to flink standalone cluster [flink-agents] via GitHub
• 2026/05/31 Re: [PR] [e2e] Add nightly e2e test for submitting examples to flink standalone cluster [flink-agents] via GitHub
• 2026/05/31 Re: [PR] [e2e] Add nightly e2e test for submitting examples to flink standalone cluster [flink-agents] via GitHub
• 2026/05/31 Re: [PR] [api][runtime][python] Expose short-term memory state TTL cleanup strategy as a config option [flink-agents] via GitHub
• 2026/05/31 [PR] [api][runtime][python] Expose short-term memory state TTL cleanup strategy as a config option [flink-agents] via GitHub
• 2026/05/31 Re: [PR] [FLINK-39775][mysql] Release snapshot split metadata after entering the stream phase [flink-cdc] via GitHub
• 2026/05/31 [PR] [integrations][api] Rename connection-layer chat() argument to modelParams [flink-agents] via GitHub
• 2026/05/31 Re: [PR] [feature][integration][java] Add built-in Google Gemini chat model integration [flink-agents] via GitHub
• 2026/05/31 Re: [PR] [FLINK-39216][helm] Add PKCS12 profile option for webhook certificate [flink-kubernetes-operator] via GitHub
• 2026/05/31 Re: [PR] [FLINK-38450][iceberg] Fix duplicate records when schema change splits writes within a checkpoint [flink-cdc] via GitHub
• 2026/05/31 Re: [PR] [FLINK-38450][iceberg] Fix duplicate records when schema change splits writes within a checkpoint [flink-cdc] via GitHub
• 2026/05/31 Re: [PR] [FLINK-38450][iceberg] Fix duplicate records when schema change splits writes within a checkpoint [flink-cdc] via GitHub
• 2026/05/31 [jira] [Commented] (FLINK-39753) RocksDB ColumnFamilyOptions and LRUCache leak in Compactor Sergey Nuyanzin (Jira)
• 2026/05/31 [jira] [Updated] (FLINK-39753) RocksDB ColumnFamilyOptions and LRUCache leak in Compactor Sergey Nuyanzin (Jira)
• 2026/05/31 Re: [PR] [FLINK-39753][state/rocksdb] Close ColumnFamilyOptions from getDescriptor() in Compactor (1.20 backport) [flink] via GitHub
• 2026/05/31 Re: [PR] [FLINK-39753][state/rocksdb] Close ColumnFamilyOptions from getDescriptor() in Compactor (1.20 backport) [flink] via GitHub
• 2026/05/31 Re: [I] [Tech Debt] Flaky live-LLM e2e/cross-language CI tests cause frequent red CI [flink-agents] via GitHub

• Earlier messages
• Later messages