issues  

Messages by Date

• 2025/08/11 Re: [PR] [FLINK-38201] SinkUpsertMaterializer should not be inserted for retract sinks [flink] via GitHub
• 2025/08/11 Re: [PR] [hotfix][python] Use `uv run` to run Python lint/testing tools, rather than directly installing [flink] via GitHub
• 2025/08/11 [jira] [Updated] (FLINK-36377) Support the use of the LAST_VALUE aggregate function on ROW type data Yang Li (Jira)
• 2025/08/11 [jira] [Updated] (FLINK-36377) Support the use of the LAST_VALUE aggregate function on ROW type data Yang Li (Jira)
• 2025/08/11 [PR] [hotfix][python] Use `uv run` to run Python lint/testing tools, rather than directly installing [flink] via GitHub
• 2025/08/11 [jira] [Updated] (FLINK-38106) Job gets indefinitely stuck with "Job Not Found" events Rasmus Bilgram (Jira)
• 2025/08/11 [jira] [Commented] (FLINK-37193) [flink-operator] Ingress recreated after perform a change to CR FlinkDeployment Jira
• 2025/08/11 [jira] [Updated] (FLINK-37193) [flink-operator] Ingress recreated after perform a change to CR FlinkDeployment ASF GitHub Bot (Jira)
• 2025/08/11 [PR] [FLINK-37193] Ingress recreated after perform a change to CR FlinkDeployment [flink-kubernetes-operator] via GitHub
• 2025/08/11 [jira] [Updated] (FLINK-38183) Data loss when cdc reading mysql that has out of order GTID LiuZeshan (Jira)
• 2025/08/11 Re: [PR] [FLINK-37065]: MySQL cdc can lose/skip data during recovering from the checkpoint [flink-cdc] via GitHub
• 2025/08/11 Re: [PR] [Feature] [API] Support Event Logger and Event Listener in Java [flink-agents] via GitHub
• 2025/08/11 Re: [PR] [FLINK-38180][task] Clean up task after switching to FAILED [flink] via GitHub
• 2025/08/11 Re: [PR] [FLINK-38180][task] Clean up task after switching to FAILED [flink] via GitHub
• 2025/08/11 Re: [PR] [hotfix] [docs] Fix typo in state v2 docs [flink] via GitHub
• 2025/08/11 [PR] [hotfix] [docs] Fix typo in state v2 docs [flink] via GitHub
• 2025/08/11 [jira] (FLINK-37802) files in directory job-result-store was incorrect jackray wang (Jira)
• 2025/08/11 [jira] [Commented] (FLINK-37802) files in directory job-result-store was incorrect jackray wang (Jira)
• 2025/08/11 [jira] [Assigned] (FLINK-38217) ChangelogNormalize unnecessarily emits updates for equal rows Sergey Nuyanzin (Jira)
• 2025/08/11 [jira] [Updated] (FLINK-38222) Upgrade HBase client version to 2.6 ASF GitHub Bot (Jira)
• 2025/08/11 Re: [PR] [FLINK-38222] Bump HBase version from 2.2 to 2.6 [flink-connector-hbase] via GitHub
• 2025/08/11 [PR] [FLINK-38222] Bump HBase version from 2.2 to 2.6 [flink-connector-hbase] via GitHub
• 2025/08/11 [jira] [Created] (FLINK-38224) Retract sink should not accept duplicate changes produced by delta join Xuyang Zhong (Jira)
• 2025/08/11 Re: [PR] [FLINK-37688] Implement Amazon CloudWatch Metric Sink Connector [flink-connector-aws] via GitHub
• 2025/08/11 Re: [PR] [FLINK-38201] SinkUpsertMaterializer should not be inserted for retract sinks [flink] via GitHub
• 2025/08/11 [jira] [Assigned] (FLINK-38224) Retract sink should not accept duplicate changes produced by delta join Xuyang Zhong (Jira)
• 2025/08/11 Re: [PR] [FLINK-38219][table-runtime][FLINK-38220][table-planner] Fix row kind in StreamingMultiJoinOperator and Add Values and TableFunctionScan as source [flink] via GitHub
• 2025/08/11 [PR] [FLINK-38219][table-runtime][FLINK-38220][table-planner] Fix row kind in StreamingMultiJoinOperator and Add Values and TableFunctionScan as source [flink] via GitHub
• 2025/08/11 [jira] [Updated] (FLINK-38219) Manipulate state in MultiJoin with fixed row kind Timo Walther (Jira)
• 2025/08/11 [jira] [Comment Edited] (FLINK-38196) IndexOutOfBoundsException when processing PostgreSQL tables with numeric(0) fields in Flink CDC tchivs (Jira)
• 2025/08/11 [jira] [Commented] (FLINK-38196) IndexOutOfBoundsException when processing PostgreSQL tables with numeric(0) fields in Flink CDC tchivs (Jira)
• 2025/08/11 Re: [PR] [FLINK-38207] Update Flink Operator to use JOSDK 5.1.2 [flink-kubernetes-operator] via GitHub
• 2025/08/11 [jira] [Commented] (FLINK-38196) IndexOutOfBoundsException when processing PostgreSQL tables with numeric(0) fields in Flink CDC Hongshun Wang (Jira)
• 2025/08/11 Re: [I] [Feature][Ollama] Add `extract_reasoning` flag to `OllamaChatModel` to capture `<think>` blocks into extra_args [flink-agents] via GitHub
• 2025/08/11 [jira] [Commented] (FLINK-37802) files in directory job-result-store was incorrect jackray wang (Jira)
• 2025/08/11 Re: [PR] [plan][runtime][python] Introduce Resource and Resource Provider in java [flink-agents] via GitHub
• 2025/08/11 Re: [PR] [api][python][java] Support serialize and deserialize AgentPlan with python resource providers. [flink-agents] via GitHub
• 2025/08/11 Re: [I] [Feature] [api][python][java] Support serialize and deserialize AgentPlan with python resource providers. [flink-agents] via GitHub
• 2025/08/11 Re: [PR] [Integration][ChatModel] Add reasoning extraction in OllamaChatModel [flink-agents] via GitHub
• 2025/08/11 Re: [PR] [FLINK-38201] SinkUpsertMaterializer should not be inserted for retract sinks [flink] via GitHub
• 2025/08/11 [jira] [Closed] (FLINK-38220) Adjust JoinToMultiJoinRule to support different types of source Dawid Wysakowicz (Jira)
• 2025/08/11 Re: [PR] [FLINK-38220][table-planner] Add Values and TableFunctionScan as sources [flink] via GitHub
• 2025/08/11 Re: [PR] [Python] Support for Event containing Row field can be json serializable [flink-agents] via GitHub
• 2025/08/11 [jira] [Commented] (FLINK-38221) PostgreSQL CDC fails to capture data from partition tables when configured with parent table names Hongshun Wang (Jira)
• 2025/08/11 [jira] [Updated] (FLINK-38219) Manipulate state in MultiJoin with fixed row kind Timo Walther (Jira)
• 2025/08/11 [jira] [Updated] (FLINK-38219) Manipulate state in MultiJoin with fixed row kind Timo Walther (Jira)
• 2025/08/11 [jira] [Commented] (FLINK-38219) Manipulate state in MultiJoin with fixed row kind Timo Walther (Jira)
• 2025/08/11 Re: [PR] [FLINK-38219][table-runtime] Set row kind once before state manipulation [flink] via GitHub
• 2025/08/11 [jira] [Updated] (FLINK-38223) ExecutionGraphRestartTest and ExecutionGraphCoLocationRestartTest are flaky on master Gustavo de Morais (Jira)
• 2025/08/11 Re: [PR] [FLINK-37955] Don't load all records into main memory to avoid OOM [flink] via GitHub
• 2025/08/11 [jira] [Comment Edited] (FLINK-38223) ExecutionGraphRestartTest and ExecutionGraphCoLocationRestartTest are flaky on master Chesnay Schepler (Jira)
• 2025/08/11 Re: [PR] [FLINK-37955] Don't load all records into main memory to avoid OOM [flink] via GitHub
• 2025/08/11 [jira] [Commented] (FLINK-38223) ExecutionGraphRestartTest and ExecutionGraphCoLocationRestartTest are flaky on master Chesnay Schepler (Jira)
• 2025/08/11 [jira] [Updated] (FLINK-37955) StreamingJoinOperator should not OOM due to collecting all matching records in memory ASF GitHub Bot (Jira)
• 2025/08/11 [PR] [FLINK-37955] Don't load all records into main memory to avoid OOM [flink] via GitHub
• 2025/08/11 Re: [PR] [FLINK-38219][table-runtime] Set row kind once before state manipulation [flink] via GitHub
• 2025/08/11 Re: [PR] [Python] Support for Event containing Row field can be json serializable [flink-agents] via GitHub
• 2025/08/11 Re: [PR] [FLINK-38219][table-runtime] Set row kind once before state manipulation [flink] via GitHub
• 2025/08/11 [jira] [Updated] (FLINK-38223) ExecutionGraphRestartTest and ExecutionGraphCoLocationRestartTest are flaky on master Gustavo de Morais (Jira)
• 2025/08/11 [jira] [Updated] (FLINK-38223) ExecutionGraphRestartTest and ExecutionGraphCoLocationRestartTest are flaky on master Gustavo de Morais (Jira)
• 2025/08/11 Re: [PR] [FLINK-38219][table-runtime] Set row kind once before state manipulation [flink] via GitHub
• 2025/08/11 [jira] [Created] (FLINK-38223) testConstraintsAfterRestart is flaky on master Gustavo de Morais (Jira)
• 2025/08/11 [PR] Remove redundant implementation of Namespaced [flink-kubernetes-operator] via GitHub
• 2025/08/11 Re: [PR] [FLINK-35907][pipeline-connector][postgres] Fix inconsistent bit type handling between snapshot and streaming phases [flink-cdc] via GitHub
• 2025/08/11 Re: [PR] [FLINK-38196][pipeline-connector][postgres] Support decimal.handling.mode config to Fix IndexOutOfBoundsException for numeric fields with NULL values ; [flink-cdc] via GitHub
• 2025/08/11 Re: [PR] [FLINK-38220][table-planner] Add Values and TableFunctionScan as sources [flink] via GitHub
• 2025/08/11 Re: [PR] [FLINK-38219][table-runtime] Set row kind once before state manipulation [flink] via GitHub
• 2025/08/11 [jira] [Resolved] (FLINK-38198) Support WITH Clause in CREATE FUNCTION Statement in Flink SQL Dawid Wysakowicz (Jira)
• 2025/08/11 Re: [PR] [FLINK-38198] Support WITH Clause in CREATE FUNCTION Statement [flink] via GitHub
• 2025/08/11 Re: [PR] [FLINK-38188][pipeline-connector][postgres] Fix database name validation logic in PostgresDataSourceFactory [flink-cdc] via GitHub
• 2025/08/11 [PR] [api][python][java] Support serialize and deserialize AgentPlan with python resource providers. [flink-agents] via GitHub
• 2025/08/11 [I] [Feature] [api][python][java] Support serialize and deserialize AgentPlan with java resource providers. [flink-agents] via GitHub
• 2025/08/11 [I] [Feature] [api][python][java] Support serialize and deserialize AgentPlan with python resource providers. [flink-agents] via GitHub
• 2025/08/11 [jira] [Created] (FLINK-38222) Upgrade HBase client version to 2.6 Mate Czagany (Jira)
• 2025/08/10 Re: [PR] [FLINK-37663] [connector-base] Address potential sync issue in FutureCompletingBlockingQueue wakeup [flink] via GitHub
• 2025/08/10 Re: [PR] [FLINK-37663] [connector-base] Address potential sync issue in FutureCompletingBlockingQueue wakeup [flink] via GitHub
• 2025/08/10 [PR] Fix usage of deprectaed method createOrUpdate from fabric8 [flink-kubernetes-operator] via GitHub
• 2025/08/10 Re: [PR] [FLINK-38193] Bump commons-lang3 to version 3.18.0 [flink] via GitHub
• 2025/08/10 [jira] [Updated] (FLINK-38221) PostgreSQL CDC fails to capture data from partition tables when configured with parent table names ASF GitHub Bot (Jira)
• 2025/08/10 [PR] [FLINK-38221][pipeline-connector][postgres] Fix critical partition table discovery bug causing CDC data loss [flink-cdc] via GitHub
• 2025/08/10 Re: [PR] [FLINK-37869][Observer] Fix finished bounded stream jobs can't be cle… [flink-kubernetes-operator] via GitHub
• 2025/08/10 [PR] Add .vscode into .gitignore [flink-kubernetes-operator] via GitHub
• 2025/08/10 [jira] [Created] (FLINK-38221) PostgreSQL CDC fails to capture data from partition tables when configured with parent table names tchivs (Jira)
• 2025/08/10 Re: [PR] [FLINK-38219][table-runtime] Set row kind once before state manipulation [flink] via GitHub
• 2025/08/10 [PR] [Feature] [API] Support Event Logger and Event Listener in Java [flink-agents] via GitHub
• 2025/08/10 Re: [PR] [FLINK-38220][table-planner] Add Values and TableFunctionScan as sources [flink] via GitHub
• 2025/08/10 Re: [PR] [FLINK-38219][table-runtime] Set row kind once before state manipulation [flink] via GitHub
• 2025/08/10 Re: [PR] [FLINK-38201] SinkUpsertMaterializer should not be inserted for retract sinks [flink] via GitHub
• 2025/08/10 Re: [PR] [FLINK-34864][cdc-connector-mysql] Add the IgnoreNoPrimaryKeyTable parameter to skip tables without primary keys in multi-table synchronization [flink-cdc] via GitHub
• 2025/08/10 Re: [PR] [FLINK-37869][Observer] Fix finished bounded stream jobs can't be cle… [flink-kubernetes-operator] via GitHub
• 2025/08/10 [PR] [FLINK-35936][cdc-connector][paimon] Fix paimon cdc schema evolution failure when restart job [flink-cdc] via GitHub
• 2025/08/10 Re: [PR] [FLINK-38188][pipeline-connector][postgres] Fix database name validation logic in PostgresDataSourceFactory [flink-cdc] via GitHub
• 2025/08/10 Re: [PR] [FLINK-35936][cdc-connector][paimon] Fix paimon cdc schema evolution failure when restart job [flink-cdc] via GitHub
• 2025/08/10 Re: [PR] [FLINK-35936][cdc-connector][paimon] Fix paimon cdc schema evolution failure when restart job [flink-cdc] via GitHub
• 2025/08/10 Re: [PR] [FLINK-37156] [cdc-composer/cli] pipeline supports collecting data once and writing it to multiple sinks. [flink-cdc] via GitHub
• 2025/08/10 Re: [PR] [FLINK-37156] [cdc-composer/cli] pipeline supports collecting data once and writing it to multiple sinks. [flink-cdc] via GitHub
• 2025/08/10 Re: [PR] [FLINK-38220][table-planner] Add Values and TableFunctionScan as sources [flink] via GitHub
• 2025/08/10 [jira] [Updated] (FLINK-38220) Adjust JoinToMultiJoinRule to support different types of source ASF GitHub Bot (Jira)
• 2025/08/10 Re: [PR] [FLINK-38219][table-runtime] Set row kind once before state manipulation [flink] via GitHub
• 2025/08/10 [PR] [FLINK-38220][table-planner] Add Values and TableFunctionScan as sources [flink] via GitHub
• 2025/08/10 [jira] [Updated] (FLINK-38219) Manipulate state in MultiJoin with fixed row kind ASF GitHub Bot (Jira)
• 2025/08/10 [PR] [FLINK-38219][table-runtime] Set row kind once before state manipulation [flink] via GitHub
• 2025/08/10 Re: [PR] [Flink-36980] [cdc-connect] Build a new introductory practice "Streaming ELT from MySQL to Kafka" [flink-cdc] via GitHub
• 2025/08/10 Re: [PR] [Flink-36980] [cdc-connect] Build a new introductory practice "Streaming ELT from MySQL to Kafka" [flink-cdc] via GitHub
• 2025/08/10 Re: [PR] [Flink-36980] [cdc-connect] Build a new introductory practice "Streaming ELT from MySQL to Kafka" [flink-cdc] via GitHub
• 2025/08/10 [jira] [Created] (FLINK-38220) Adjust JoinToMultiJoinRule to support different types of source Gustavo de Morais (Jira)
• 2025/08/10 [jira] [Created] (FLINK-38219) Manipulate state in MultiJoin with fixed row kind Gustavo de Morais (Jira)
• 2025/08/10 Re: [PR] [FLINK-37065]: MySQL cdc can lose/skip data during recovering from the checkpoint [flink-cdc] via GitHub
• 2025/08/10 Re: [PR] [FLINK-38188][pipeline-connector][postgres] Fix database name validation logic in PostgresDataSourceFactory [flink-cdc] via GitHub
• 2025/08/10 Re: [PR] [FLINK-37869][Observer] Fix finished bounded stream jobs can't be cle… [flink-kubernetes-operator] via GitHub
• 2025/08/10 Re: [PR] [FLINK-38159] Update commons-lang3 dependency to 3.18.0 [flink-kubernetes-operator] via GitHub
• 2025/08/10 Re: [PR] [FLINK-38207] Update Flink Operator to use JOSDK 5.1.2 [flink-kubernetes-operator] via GitHub
• 2025/08/10 Re: [PR] [FLINK-37515] Basic support for Blue/Green deployments [flink-kubernetes-operator] via GitHub
• 2025/08/10 Re: [PR] [FLINK-37688] Implement Amazon CloudWatch Metric Sink Connector [flink-connector-aws] via GitHub
• 2025/08/10 [I] [Feature] [api] Support Event Logger and Event Listener in Java [flink-agents] via GitHub
• 2025/08/10 Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] via GitHub
• 2025/08/09 Re: [PR] [hotfix] [docs] Correct inaccurate description of JobMaster's role in Flink JobManager [flink] via GitHub
• 2025/08/09 Re: [PR] [hotfix] [docs] Correct inaccurate description of JobMaster's role in Flink JobManager [flink] via GitHub
• 2025/08/09 Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] via GitHub
• 2025/08/09 Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] via GitHub
• 2025/08/09 Re: [PR] [FLINK-38188][cdc-postgres] Fix database name validation logic in PostgresDataSourceFactory [flink-cdc] via GitHub
• 2025/08/09 Re: [PR] [FLINK-37065]: MySQL cdc can lose/skip data during recovering from the checkpoint [flink-cdc] via GitHub
• 2025/08/09 Re: [PR] [FLINK-37963] Fix potential NPE when triggering JobManager failover prematurely [flink-cdc] via GitHub
• 2025/08/09 Re: [PR] [pipeline-connector/paimon] Support table specific table.properties configuration [flink-cdc] via GitHub
• 2025/08/09 Re: [PR] [FLINK-36813][cdc-connectors][mysql] support mysql sync part columns [flink-cdc] via GitHub
• 2025/08/09 Re: [PR] [FLINK-38193] Bump commons-lang3 to version 3.18.0 [flink] via GitHub
• 2025/08/09 Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] via GitHub
• 2025/08/09 Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] via GitHub
• 2025/08/09 Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] via GitHub
• 2025/08/09 Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] via GitHub
• 2025/08/09 [PR] [Integration][ChatModel] Add reasoning extraction in OllamaChatModel [flink-agents] via GitHub
• 2025/08/09 Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] via GitHub
• 2025/08/09 [I] [Feature][Ollama] Add `extract_reasoning` flag to `OllamaChatModel` to capture `<think>` blocks into extra_args [flink-agents] via GitHub
• 2025/08/09 Re: [PR] [FLINK-38059][doc] Add fluss pipeline connector documentation [flink-cdc] via GitHub
• 2025/08/09 [jira] [Assigned] (FLINK-38215) Remove HA data according to config option `job.savepoint-on-deletion` when cleanup terminal JM after ttl passed Rui Fan (Jira)
• 2025/08/09 [jira] [Resolved] (FLINK-38142) Bump the version of Paimon flink to 1.2.0 Yanquan Lv (Jira)
• 2025/08/09 Re: [PR] [FLINK-38142] Upgrading the Paimon version to 1.2.0 [flink-cdc] via GitHub
• 2025/08/08 Re: [I] [Feature][plan][runtime] Introduce Resource and Resource Provider [flink-agents] via GitHub
• 2025/08/08 Re: [PR] [plan][runtime][java] Introduce Resource and Resource Provider in java [flink-agents] via GitHub
• 2025/08/08 [jira] [Commented] (FLINK-38191) [Document] Add document for Fluss pipeline connector JunboWang (Jira)
• 2025/08/08 [PR] [FLINK-38059][doc] Add fluss pipeline connector documentation [flink-cdc] via GitHub
• 2025/08/08 [jira] [Updated] (FLINK-38059) [docs] Add fluss pipeline connector documentation ASF GitHub Bot (Jira)
• 2025/08/08 Re: [I] [Feature][plan][runtime][java] Introduce Resource and Resource Provider in java [flink-agents] via GitHub
• 2025/08/08 Re: [PR] [FLINK-34820][mysql] Not recycle but reuse fetcher for all data to improve performant [flink-cdc] via GitHub
• 2025/08/08 Re: [PR] [FLINK-38218] Fix MySQL CDC binlog split metadata split transmission [flink-cdc] via GitHub
• 2025/08/08 [jira] [Updated] (FLINK-38218) MySQL CDC source may ignore newly added tables while reading the binlog ASF GitHub Bot (Jira)
• 2025/08/08 [PR] [FLINK-38218] Fix MySQL CDC binlog split metadata split transmission [flink-cdc] via GitHub
• 2025/08/08 [jira] [Updated] (FLINK-38218) MySQL CDC source may ignore newly added tables while reading the binlog Sergei Morozov (Jira)
• 2025/08/08 Re: [PR] [hotfix][docs] `WITH` in `CREATE` `CATALOG`, `DATABASE`, `MODEL` is optional [flink] via GitHub
• 2025/08/08 Re: [PR] [hotfix][docs] `WITH` in `CREATE` `CATALOG`, `DATABASE`, `MODEL` is optional [flink] via GitHub
• 2025/08/08 Re: [PR] [hotfix][docs] `WITH` in `CREATE` `CATALOG`, `DATABASE`, `MODEL` is optional [flink] via GitHub
• 2025/08/08 Re: [PR] [hotfix][docs] `WITH` in `CREATE` `CATALOG`, `DATABASE`, `MODEL` is optional [flink] via GitHub
• 2025/08/08 Re: [PR] [hotfix][docs] `WITH` in `CREATE` `CATALOG`, `DATABASE`, `MODEL` is optional [flink] via GitHub
• 2025/08/08 [PR] [hotfix][docs] `WITH` in `CREATE` `CATALOG`, `DATABASE`, `MODEL` is optional [flink] via GitHub
• 2025/08/08 Re: [PR] [pipeline-connector/paimon] Support table specific table.properties configuration [flink-cdc] via GitHub
• 2025/08/08 [jira] [Updated] (FLINK-38218) MySQL CDC source may ignore newly added tables while reading the binlog Sergei Morozov (Jira)
• 2025/08/08 [jira] [Updated] (FLINK-38218) MySQL CDC source may ignore newly added tables while reading the binlog Sergei Morozov (Jira)
• 2025/08/08 [jira] [Created] (FLINK-38218) MySQL CDC source may ignore newly added tables while reading the binlog Sergei Morozov (Jira)
• 2025/08/08 Re: [PR] [plan][runtime][java] Introduce Resource and Resource Provider in java [flink-agents] via GitHub
• 2025/08/08 Re: [PR] [FLINK-38201] SinkUpsertMaterializer should not be inserted for retract sinks [flink] via GitHub
• 2025/08/08 Re: [PR] Fix watermark documentation [flink] via GitHub
• 2025/08/08 [PR] Fix watermark documentation [flink] via GitHub
• 2025/08/08 [jira] [Updated] (FLINK-38211) Refactor explain for MultiJoin operator Gustavo de Morais (Jira)
• 2025/08/08 [jira] [Updated] (FLINK-38211) Refactor explain for MultiJoin operator Gustavo de Morais (Jira)
• 2025/08/08 [jira] [Assigned] (FLINK-38073) Add documentation for the MultiJoin Operator Gustavo de Morais (Jira)
• 2025/08/08 [jira] [Updated] (FLINK-38209) Use UniqueKeys instead of Upsertkeys for state management Timo Walther (Jira)
• 2025/08/08 [jira] [Closed] (FLINK-38209) Use UniqueKeys instead of Upsertkeys for state management Timo Walther (Jira)
• 2025/08/08 Re: [PR] [FLINK-38209][table-planner] Use UniqueKeys instead of Upsertkeys for inputSpec and state management for MultiJoin [flink] via GitHub
• 2025/08/08 Re: [PR] [Python] Support for Event containing Row field can be json serializable [flink-agents] via GitHub
• 2025/08/08 [PR] [hotfix][docs] Clarify Kryo behavior [flink] via GitHub
• 2025/08/08 Re: [PR] [hotfix][docs] Clarify Kryo behavior [flink] via GitHub
• 2025/08/08 [jira] [Created] (FLINK-38217) ChangelogNormalize unnecessarily emits updates for equal rows Dawid Wysakowicz (Jira)
• 2025/08/08 [jira] [Resolved] (FLINK-38111) Migrate OceanBase CDC Connector from LogProxy to OceanBase Binlog Service yuan (Jira)
• 2025/08/08 [jira] [Reopened] (FLINK-38111) Migrate OceanBase CDC Connector from LogProxy to OceanBase Binlog Service yuan (Jira)
• 2025/08/08 [jira] [Commented] (FLINK-38192) Improve DynamicSourceUtils exception msg Cai Liuyang (Jira)
• 2025/08/08 Re: [PR] [FLINK-38209][table-planner] Use UniqueKeys instead of Upsertkeys for inputSpec and state management for MultiJoin [flink] via GitHub
• 2025/08/08 Re: [PR] [FLINK-38209][table-planner] Use UniqueKeys instead of Upsertkeys for inputSpec and state management for MultiJoin [flink] via GitHub
• 2025/08/08 Re: [PR] [FLINK-38142] Upgrading the Paimon version to 1.2.0 [flink-cdc] via GitHub
• 2025/08/08 Re: [PR] [FLINK-38209][table-planner] Use UniqueKeys instead of Upsertkeys for inputSpec and state management for MultiJoin [flink] via GitHub
• 2025/08/08 Re: [PR] [FLINK-38198] Support WITH Clause in CREATE FUNCTION Statement [flink] via GitHub
• 2025/08/08 Re: [PR] [plan][runtime][java] Introduce Resource and Resource Provider in java [flink-agents] via GitHub
• 2025/08/08 [jira] [Created] (FLINK-38216) Refactor EndOfChannelStateEvent according to input buffer and output buffer Rui Fan (Jira)
• 2025/08/08 [jira] [Updated] (FLINK-37963) Unstable MongoDB unit test cases that triggers JM failover ASF GitHub Bot (Jira)
• 2025/08/08 [jira] [Updated] (FLINK-37835) MySQL CDC BinlogOffset compareTo method throws NPE Yanquan Lv (Jira)
• 2025/08/08 Re: [PR] [FLINK-37963] Fix potential NPE when triggering JobManager failover prematurely [flink-cdc] via GitHub
• 2025/08/08 [jira] [Updated] (FLINK-38204) When using route in pipeline, failed to write to MaxCompute sink Yanquan Lv (Jira)
• 2025/08/08 [jira] [Assigned] (FLINK-38204) When using route in pipeline, failed to write to MaxCompute sink Yanquan Lv (Jira)
• 2025/08/08 [jira] [Commented] (FLINK-38204) When using route in pipeline, failed to write to MaxCompute sink wuzexian (Jira)
• 2025/08/08 [jira] [Commented] (FLINK-37835) MySQL CDC BinlogOffset compareTo method throws NPE wuzexian (Jira)
• 2025/08/08 Re: [PR] [FLINK-37905] Fix transform failure with non-ascii string literals [flink-cdc] via GitHub
• 2025/08/08 [jira] [Commented] (FLINK-37835) MySQL CDC BinlogOffset compareTo method throws NPE Xiqian Yu (Jira)
• 2025/08/08 [jira] [Assigned] (FLINK-38204) When using route in pipeline, failed to write to MaxCompute sink Yanquan Lv (Jira)
• 2025/08/08 [jira] [Assigned] (FLINK-37835) MySQL CDC BinlogOffset compareTo method throws NPE Xiqian Yu (Jira)
• 2025/08/08 [jira] [Updated] (FLINK-38194) Iceberg connector supports auto-creating namespace Yanquan Lv (Jira)
• 2025/08/07 Re: [PR] [FLINK-37479][postgres] Add support for PARTITIONED TABLE [flink-cdc] via GitHub
• 2025/08/07 [jira] [Resolved] (FLINK-38194) Iceberg connector supports auto-creating namespace Yanquan Lv (Jira)
• 2025/08/07 [jira] [Resolved] (FLINK-38154) Add HTTP support to OpenTelemetry Reporter Robert Metzger (Jira)
• 2025/08/07 Re: [PR] [FLINK-38194][pipeline-connector/iceberg] Iceberg connector supports auto-creating namespace [flink-cdc] via GitHub
• 2025/08/07 [jira] [Created] (FLINK-38215) Remove HA data according to config option `job.savepoint-on-deletion` when cleanup terminal JM after ttl passed junzhong qin (Jira)
• 2025/08/07 [jira] [Updated] (FLINK-38215) Remove HA data according to config option `job.savepoint-on-deletion` when cleanup terminal JM after ttl passed junzhong qin (Jira)

• Earlier messages
• Later messages