issues  

Messages by Date

• 2026/06/02 [PR] [FLINK-39825] Add support for State TTL and eviction in ProcessTableFunctionTestHarness [flink] via GitHub
• 2026/06/02 [jira] [Assigned] (FLINK-39825) Add support for state TTL in ProcessTableFunctionTestHarness Mika Naylor (Jira)
• 2026/06/02 [jira] [Closed] (FLINK-39381) Add user facing documentation for ProcessTableFunctionTestHarness Mika Naylor (Jira)
• 2026/06/02 [jira] [Resolved] (FLINK-39790) State latency/size tracking metrics not exported without sampling Rui Fan (Jira)
• 2026/06/02 [jira] [Created] (FLINK-39825) Add support for state TTL in ProcessTableFunctionTestHarness Mika Naylor (Jira)
• 2026/06/02 Re: [PR] [FLINK-39790][state/metrics] Fix State latency/size tracking metrics not exported without sampling [flink] via GitHub
• 2026/06/02 [jira] [Updated] (FLINK-39824) [mysql-cdc] High CPU usage caused by repeated regex table filtering in large table synchronization Ran Tao (Jira)
• 2026/06/02 Re: [PR] [FLINK-39792] Add multi-headers metadata key to Kafka connector [flink-connector-kafka] via GitHub
• 2026/06/02 Re: [PR] [FLINK-39824][mysql] Cache table filter results to reduce regex matching [flink-cdc] via GitHub
• 2026/06/02 [jira] [Commented] (FLINK-39824) [mysql-cdc] High CPU usage caused by repeated regex table filtering in large table synchronization Ran Tao (Jira)
• 2026/06/02 [jira] [Updated] (FLINK-39824) [mysql-cdc] High CPU usage caused by repeated regex table filtering in large table synchronization Ran Tao (Jira)
• 2026/06/02 [jira] [Updated] (FLINK-39824) [mysql-cdc] High CPU usage caused by repeated regex table filtering in large table synchronization ASF GitHub Bot (Jira)
• 2026/06/02 [PR] [FLINK-39824][mysql] Cache table filter results to reduce regex matching [flink-cdc] via GitHub
• 2026/06/02 [jira] [Created] (FLINK-39824) [mysql-cdc] High CPU usage caused by repeated regex table filtering in large table synchronization Ran Tao (Jira)
• 2026/06/02 Re: [D] [Discussion] Trigger action by Event Field Values [flink-agents] via GitHub
• 2026/06/02 Re: [D] [Discussion] Trigger action by Event Field Values [flink-agents] via GitHub
• 2026/06/02 Re: [D] [Discussion] Trigger action by Event Field Values [flink-agents] via GitHub
• 2026/06/02 Re: [D] [Discussion] Trigger @Action by Event Field Values [flink-agents] via GitHub
• 2026/06/02 Re: [D] [Discussion] Trigger @Action by Event Field Values [flink-agents] via GitHub
• 2026/06/02 Re: [D] [DISCUSS] Support Field-Based Conditions for @Action Triggers [flink-agents] via GitHub
• 2026/06/02 Re: [D] [DISCUSS] Trigger @Action by Event Field Values [flink-agents] via GitHub
• 2026/06/02 [D] [DISCUSS] Support Field-Based Conditions for @Action Triggers [flink-agents] via GitHub
• 2026/06/02 [jira] [Created] (FLINK-39823) SystemTypeInference infers incorrect partition key Timo Walther (Jira)
• 2026/06/02 Re: [PR] [FLINK-36973][config] Skip options not explicitly set when converting SavepointRestoreSettings to Configuration [flink] via GitHub
• 2026/06/02 [PR] [FLINK-36973][config] Skip options not explicitly set when converting SavepointRestoreSettings to Configuration [flink] via GitHub
• 2026/06/02 Re: [PR] [FLINK-39790][state/metrics] Fix State latency/size tracking metrics not exported without sampling [flink] via GitHub
• 2026/06/02 Re: [I] [Bug] AgentPlan resource getter is not thread-safe on release-0.2 [flink-agents] via GitHub
• 2026/06/02 [jira] [Created] (FLINK-39822) All createTopics calls in tests should wait for partition assignment Aleksandr Savonin (Jira)
• 2026/06/02 [jira] [Updated] (FLINK-39723) KafkaTableITCase.testExactlyOnceSink fails due to transactional ID reuse across test runs Aleksandr Savonin (Jira)
• 2026/06/02 Re: [PR] [FLINK-38697][runtime] Store task information blob key in JobVertex [flink] via GitHub
• 2026/06/02 Re: [PR] [FLINK-39790][state/metrics] Fix State latency/size tracking metrics not exported without sampling [flink] via GitHub
• 2026/06/02 Re: [PR] [FLINK-39651][table] REGEXP plan-time validation and hot-path log cleanup [flink] via GitHub
• 2026/06/02 Re: [PR] [FLINK-39651][table] REGEXP plan-time validation and hot-path log cleanup [flink] via GitHub
• 2026/06/02 Re: [PR] [FLINK-39651][table] REGEXP plan-time validation and hot-path log cleanup [flink] via GitHub
• 2026/06/02 Re: [PR] [FLINK-39811][s3] Optionally Adjust s5cmd part size to fully utilize s5cmd workers pool during downloads [flink] via GitHub
• 2026/06/02 Re: [PR] [FLINK-39651][table] REGEXP plan-time validation and hot-path log cleanup [flink] via GitHub
• 2026/06/02 [jira] [Updated] (FLINK-39790) State latency/size tracking metrics not exported without sampling ASF GitHub Bot (Jira)
• 2026/06/02 Re: [PR] [FLINK-39790][state/metrics] Fix State latency/size tracking metrics not exported without sampling [flink] via GitHub
• 2026/06/02 Re: [PR] [FLINK-39651][table] REGEXP plan-time validation and hot-path log cleanup [flink] via GitHub
• 2026/06/02 [jira] [Assigned] (FLINK-39790) State latency/size tracking metrics not exported without sampling Rui Fan (Jira)
• 2026/06/02 [jira] [Commented] (FLINK-39510) Add Chinese translation about AI-assisted contributions Nuozheng (Jira)
• 2026/06/02 Re: [PR] [FLINK-39651][table] REGEXP plan-time validation and hot-path log cleanup [flink] via GitHub
• 2026/06/02 Re: [PR] [FLINK-39651][table] REGEXP plan-time validation and hot-path log cleanup [flink] via GitHub
• 2026/06/02 Re: [PR] [FLINK-39651][table] REGEXP plan-time validation and hot-path log cleanup [flink] via GitHub
• 2026/06/02 Re: [PR] [FLINK-39651][table] REGEXP plan-time validation and hot-path log cleanup [flink] via GitHub
• 2026/06/02 Re: [PR] [FLINK-39637][state] Add filter pushdown support for savepoint connector [flink] via GitHub
• 2026/06/02 Re: [PR] [FLINK-39258][table] Extend restore tests for TO_CHANGELOG and FROM_CHANGELOG [flink] via GitHub
• 2026/06/02 Re: [PR] [FLINK-39258][table] Extend restore tests for TO_CHANGELOG and FROM_CHANGELOG [flink] via GitHub
• 2026/06/02 Re: [PR] [FLINK-39258][table] Extend restore tests for TO_CHANGELOG and FROM_CHANGELOG [flink] via GitHub
• 2026/06/02 Re: [PR] [FLINK-39820][docs] Update delta join documentation with new features in 2.3 [flink] via GitHub
• 2026/06/02 Re: [PR] [FLINK-39820][docs] Update delta join documentation with new features in 2.3 [flink] via GitHub
• 2026/06/02 [PR] [FLINK-39820][docs] Update delta join documentation with new features in 2.3 [flink] via GitHub
• 2026/06/02 [jira] [Updated] (FLINK-39820) Update delta join documentation with new features in 2.3 ASF GitHub Bot (Jira)
• 2026/06/02 Re: [PR] [FLINK-39821][table] Make REGEXP_REPLACE return type nullable [flink] via GitHub
• 2026/06/02 [jira] [Updated] (FLINK-39820) Update delta join documentation with new features in 2.3 Xuyang Zhong (Jira)
• 2026/06/02 [jira] [Updated] (FLINK-39820) Update delta join documentation with new features in Flink 2.3 Xuyang Zhong (Jira)
• 2026/06/02 [jira] [Updated] (FLINK-39821) Make return type of REGEX_REPLACE nullable ASF GitHub Bot (Jira)
• 2026/06/02 Re: [PR] [FLINK-39650][table] REGEXP_REPLACE plan-time validation and hot-path log cleanup [flink] via GitHub
• 2026/06/02 [PR] [FLINK-39821][table] Make REGEXP_REPLACE return type nullable [flink] via GitHub
• 2026/06/02 Re: [PR] [FLINK-39811][s3] Optionally Adjust s5cmd part size to fully utilize s5cmd workers pool during downloads [flink] via GitHub
• 2026/06/02 [jira] [Assigned] (FLINK-39811) S5cmd effective concurrency capped by static part size for small downloads Piotr Nowojski (Jira)
• 2026/06/02 [jira] [Assigned] (FLINK-39821) Make return type of REGEX_REPLACE nullable Ramin Gharib (Jira)
• 2026/06/02 Re: [PR] [FLINK-39651][table] REGEXP plan-time validation and hot-path log cleanup [flink] via GitHub
• 2026/06/02 [jira] [Created] (FLINK-39821) Make return type of REGEX_REPLACE nullable Ramin Gharib (Jira)
• 2026/06/02 [jira] [Created] (FLINK-39820) Add doc for delta join in 2.3 Xuyang Zhong (Jira)
• 2026/06/02 [jira] [Updated] (FLINK-39651) REGEXP predicate does not validate literal regex patterns at plan time and logs errors on the hot path ASF GitHub Bot (Jira)
• 2026/06/02 [PR] [FLINK-39651][table] REGEXP plan-time validation and hot-path log cleanup [flink] via GitHub
• 2026/06/02 Re: [PR] [FLINK-39176][runtime] Introduce NodeHealthManager abstraction [flink] via GitHub
• 2026/06/02 Re: [PR] [FLINK-39176][runtime] Integrate NodeHealthManager with Slot Filtering [flink] via GitHub
• 2026/06/02 [jira] [Commented] (FLINK-39673) SQL jobs may ignore user-configured claim mode with deprecated config key Han Yin (Jira)
• 2026/06/02 [jira] [Commented] (FLINK-39426) Flink 2.0 and Connector version compatibility issue Robert Metzger (Jira)
• 2026/06/02 Re: [PR] [FLINK-39818][ci] Filter org.eclipse.parsson:parsson false positive for Elasticsearch connector [flink] via GitHub
• 2026/06/02 Re: [PR] [FLINK-39816] Ship parsson into es8 uber jar [flink-connector-elasticsearch] via GitHub
• 2026/06/02 Re: [PR] [FLINK-39818][ci] Filter org.eclipse.parsson:parsson false positive for Elasticsearch connector [flink] via GitHub
• 2026/06/02 Re: [PR] [FLINK-39817][table] Upgrade Calcite version to 1.39.0 [flink] via GitHub
• 2026/06/02 [jira] [Updated] (FLINK-39818) Filter org.eclipse.parsson:parsson false positive for Elasticsearch connector ASF GitHub Bot (Jira)
• 2026/06/02 [PR] [FLINK-39818][ci] Filter org.eclipse.parsson:parsson false positive for Elasticsearch connector [flink] via GitHub
• 2026/06/02 Re: [PR] [FLINK-XXXXX][table] Add config option and Catalog API for table to materialized table conversion [flink] via GitHub
• 2026/06/02 [jira] [Updated] (FLINK-39817) Upgrade Calcite version to 1.39.0 ASF GitHub Bot (Jira)
• 2026/06/02 [PR] [FLINK-39817][table] Upgrade Calcite version to 1.39.0 [flink] via GitHub
• 2026/06/02 [jira] [Updated] (FLINK-39819) Avoid redundant JSON String round-trips in SpecUtils.clone and DiffResult.toString ASF GitHub Bot (Jira)
• 2026/06/02 [PR] [FLINK-39819] Avoid redundant JSON String round-trips in SpecUtils.clone and DiffResult.toString [flink-kubernetes-operator] via GitHub
• 2026/06/02 [jira] [Created] (FLINK-39819) Avoid redundant JSON String round-trips in SpecUtils.clone and DiffResult.toString Dennis-Mircea Ciupitu (Jira)
• 2026/06/02 [jira] [Updated] (FLINK-39816) ES8 SQL sink can not parse response as missing dependency ASF GitHub Bot (Jira)
• 2026/06/02 [PR] [FLINK-39816] Ship parsson into es8 uber jar [flink-connector-elasticsearch] via GitHub
• 2026/06/02 [jira] [Updated] (FLINK-39818) Filter org.eclipse.parsson:parsson false positive for Elasticsearch connector reswqa (Jira)
• 2026/06/02 Re: [PR] [feature][integration][java] Add built-in Google Gemini chat model integration [flink-agents] via GitHub
• 2026/06/02 [jira] [Created] (FLINK-39818) Filter org.eclipse.parsson:parsson false positive for Elasticsearch connector reswqa (Jira)
• 2026/06/02 [PR] [FLINK-39743] [flink-autoscaler] Fix incorrect expected processing rate computation [flink-kubernetes-operator] via GitHub
• 2026/06/02 [jira] [Updated] (FLINK-39743) Incorrect Expected Processing Rate Computation ASF GitHub Bot (Jira)
• 2026/06/01 [jira] [Created] (FLINK-39817) Upgrade Calcite version to 1.39.0 Sergey Nuyanzin (Jira)
• 2026/06/01 Re: [PR] [FLINK-36602][table] Upgrade Calcite version to 1.38.0 [flink] via GitHub
• 2026/06/01 Re: [PR] [FLINK-39570] Update dependencies to latest versions [flink-shaded] via GitHub
• 2026/06/01 [jira] [Created] (FLINK-39816) ES8 SQL sink can not parse response as missing dependency reswqa (Jira)
• 2026/06/01 [jira] [Commented] (FLINK-38698) TaskInformation blobs accumulate without cleanup causing storage exhaustion Spoorthi Basu (Jira)
• 2026/06/01 Re: [I] [Bug] AgentPlan resource getter is not thread-safe on release-0.2 [flink-agents] 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] [Comment Edited] (FLINK-39426) Flink 2.0 and Connector version compatibility issue Paras Negi (Jira)
• 2026/06/01 [jira] [Commented] (FLINK-39426) Flink 2.0 and Connector version compatibility issue Paras Negi (Jira)
• 2026/06/01 Re: [PR] [FLINK-36602][table] Upgrade Calcite version to 1.38.0 [flink] via GitHub
• 2026/06/01 [jira] (FLINK-39426) Flink 2.0 and Connector version compatibility issue Paras Negi (Jira)
• 2026/06/01 [jira] [Comment Edited] (FLINK-39426) Flink 2.0 and Connector version compatibility issue Paras Negi (Jira)
• 2026/06/01 [jira] [Comment Edited] (FLINK-39426) Flink 2.0 and Connector version compatibility issue Paras Negi (Jira)
• 2026/06/01 [jira] [Commented] (FLINK-39426) Flink 2.0 and Connector version compatibility issue Paras Negi (Jira)
• 2026/06/01 Re: [I] [Feature] Expose short-term memory state TTL cleanup strategy as a config option [flink-agents] via GitHub
• 2026/06/01 Re: [I] [Feature] Expose short-term memory state TTL cleanup strategy as a config option [flink-agents] via GitHub
• 2026/06/01 Re: [PR] [api][runtime][python] Expose short-term memory state TTL cleanup strategy as a config option [flink-agents] via GitHub
• 2026/06/01 Re: [PR] [api][runtime][python] Expose short-term memory state TTL cleanup strategy as a config option [flink-agents] via GitHub
• 2026/06/01 Re: [PR] [api][runtime][python] Expose short-term memory state TTL cleanup strategy as a config option [flink-agents] via GitHub
• 2026/06/01 Re: [I] [Bug] Java chat token metrics are recorded inside async call boundary [flink-agents] via GitHub
• 2026/06/01 Re: [I] [Bug] Java chat token metrics are recorded inside async call boundary [flink-agents] via GitHub
• 2026/06/01 Re: [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 Re: [PR] [FLINK-39730][runtime] Honor maxExceptions on ApplicationExceptionsHandler [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 Gerk Elznik (Jira)
• 2026/06/01 [jira] [Updated] (FLINK-39791) Helm chart silently ignores defaultConfiguration.config.yaml; always mounts flink-conf.yaml from chart defaults ASF GitHub Bot (Jira)
• 2026/06/01 [PR] [FLINK-39791][helm] Honor defaultConfiguration.config.yaml and always mount config.yaml [flink-kubernetes-operator] via GitHub
• 2026/06/01 Re: [PR] Add option to retain removed dynamic Kafka cluster offsets in checkpoints [flink-connector-kafka] via GitHub
• 2026/06/01 Re: [PR] [FLINK-39637][state] Add filter pushdown support for savepoint connector [flink] via GitHub
• 2026/06/01 [jira] [Resolved] (FLINK-39812) Migrate FlinkTypeFactory to java Sergey Nuyanzin (Jira)
• 2026/06/01 Re: [PR] [FLINK-39812][table] Migrate `FlinkTypeFactory` to java [flink] via GitHub
• 2026/06/01 [jira] [Commented] (FLINK-39812) Migrate FlinkTypeFactory to java Sergey Nuyanzin (Jira)
• 2026/06/01 [jira] [Commented] (FLINK-39723) KafkaTableITCase.testExactlyOnceSink fails due to transactional ID reuse across test runs Martijn Visser (Jira)
• 2026/06/01 [jira] [Updated] (FLINK-39723) KafkaTableITCase.testExactlyOnceSink fails due to transactional ID reuse across test runs Martijn Visser (Jira)
• 2026/06/01 Re: [PR] [FLINK-39723] Wait for partition assignment in KafkaTableTestBase.createTestTopic [flink-connector-kafka] via GitHub
• 2026/06/01 [jira] [Commented] (FLINK-39815) Mark SecurityManager related tests with FailsOnJava25 Sergey Nuyanzin (Jira)
• 2026/06/01 [jira] [Resolved] (FLINK-39815) Mark SecurityManager related tests with FailsOnJava25 Sergey Nuyanzin (Jira)
• 2026/06/01 Re: [PR] [FLINK-39815][tests] Mark SecurityManager related tests with `FailsOnJava25` [flink] via GitHub
• 2026/06/01 Re: [PR] [FLINK-39815][tests] Mark SecurityManager related tests with `FailsOnJava25` [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 Re: [PR] [FLINK-39723] Wait for partition assignment in KafkaTableTestBase.createTestTopic [flink-connector-kafka] 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 Re: [PR] [FLINK-39136][filesystems] Bump google-cloud-storage to 2.68.0 in flink-gs-fs-hadoop [flink] via GitHub
• 2026/06/01 [PR] [FLINK-39723] Wait for partition assignment in KafkaTableTestBase.createTestTopic [flink-connector-kafka] via GitHub
• 2026/06/01 [jira] [Updated] (FLINK-39723) KafkaTableITCase.testExactlyOnceSink fails due to transactional ID reuse across test runs ASF GitHub Bot (Jira)
• 2026/06/01 [jira] [Commented] (FLINK-39723) KafkaTableITCase.testExactlyOnceSink fails due to transactional ID reuse across test runs Aleksandr Savonin (Jira)
• 2026/06/01 Re: [I] [Feature] Support using cross-language actions. [flink-agents] via GitHub
• 2026/06/01 Re: [PR] [hotfix] Retain removed dynamic Kafka cluster offsets in checkpoints [flink-connector-kafka] via GitHub
• 2026/06/01 [PR] [hotfix] Retain removed dynamic Kafka cluster offsets in checkpoints [flink-connector-kafka] via GitHub
• 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 Re: [PR] [FLINK-39637][state] Add filter pushdown support for savepoint connector [flink] via GitHub
• 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-39814) FlinkStateSnapshot-triggered savepoints ignore the referenced FlinkSessionJob state.savepoints.dir ASF GitHub Bot (Jira)
• 2026/06/01 Re: [PR] [FLINK-39815][tests] Mark SecurityManager related tests with `FailsOnJava25` [flink] via GitHub
• 2026/06/01 [PR] [FLINK-39814] Honor FlinkSessionJob savepoint dir in snapshots [flink-kubernetes-operator] via GitHub
• 2026/06/01 [PR] Rewrite security page with precise trust model and operator coverage [flink-web] via GitHub
• 2026/06/01 [jira] [Commented] (FLINK-39723) KafkaTableITCase.testExactlyOnceSink fails due to transactional ID reuse across test runs Martijn Visser (Jira)
• 2026/06/01 [jira] [Updated] (FLINK-39815) Mark SecurityManager related tests with FailsOnJava25 ASF GitHub Bot (Jira)
• 2026/06/01 [PR] [FLINK-39815][tests] Mark SecurityManager related tests with `FailsOnJava25` [flink] via GitHub
• 2026/06/01 [jira] [Created] (FLINK-39815) Mark SecurityManager related tests with FailsOnJava25 Sergey Nuyanzin (Jira)
• 2026/06/01 [jira] [Updated] (FLINK-39814) FlinkStateSnapshot-triggered savepoints ignore the referenced FlinkSessionJob state.savepoints.dir lrsb (Jira)
• 2026/06/01 [jira] [Created] (FLINK-39814) FlinkStateSnapshot-triggered savepoints ignore the referenced FlinkSessionJob state.savepoints.dir lrsb (Jira)
• 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-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-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-39812][table] Migrate `FlinkTypeFactory` to java [flink] via GitHub
• 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

• Earlier messages
• Later messages