issues  

Messages by Thread

• [jira] [Updated] (FLINK-38305) amend the prefix to not include gid and move to http david radley (Jira)
• [jira] [Commented] (FLINK-38325) Checkpoints are hanging and timing out frequently Zakelly Lan (Jira)
  • [jira] [Commented] (FLINK-38325) Checkpoints are hanging and timing out frequently Zakelly Lan (Jira)
• [jira] [Commented] (FLINK-38326) Kubernetes support oAuthToken authentication Gabor Somogyi (Jira)
  • [jira] [Commented] (FLINK-38326) Kubernetes support oAuthToken authentication Gabor Somogyi (Jira)
  • [jira] [Commented] (FLINK-38326) Kubernetes support oAuthToken authentication melin (Jira)
• [jira] [Commented] (FLINK-38327) NPE during recovery from file-merged checkpoint after FO Gabor Somogyi (Jira)
  • [jira] [Commented] (FLINK-38327) NPE during recovery from file-merged checkpoint after FO Zakelly Lan (Jira)
  • [jira] [Commented] (FLINK-38327) NPE during recovery from file-merged checkpoint after FO Zakelly Lan (Jira)
• [jira] [Updated] (FLINK-38326) Kubernetes support oAuthToken authentication melin (Jira)
  • [jira] [Updated] (FLINK-38326) Kubernetes support oAuthToken authentication melin (Jira)
  • [jira] [Updated] (FLINK-38326) Kubernetes support oAuthToken authentication melin (Jira)
  • [jira] [Updated] (FLINK-38326) Kubernetes support oAuthToken authentication melin (Jira)
  • [jira] [Updated] (FLINK-38326) Kubernetes support oAuthToken authentication melin (Jira)
  • [jira] [Updated] (FLINK-38326) Kubernetes support oAuthToken authentication Xuannan Su (Jira)
  • [jira] [Updated] (FLINK-38326) Kubernetes support oAuthToken authentication Gabor Somogyi (Jira)
  • [jira] [Updated] (FLINK-38326) Kubernetes support oAuthToken authentication Gabor Somogyi (Jira)
• [jira] [Closed] (FLINK-38180) Race condition between failing Task and cancelation hiding the real exception Piotr Nowojski (Jira)
• [jira] [Created] (FLINK-38327) NPE during recovery from file-merged checkpoint after FO Zakelly Lan (Jira)
• [jira] [Assigned] (FLINK-38291) Reduce thread lock overhead for Flink UI REST handlers Xuannan Su (Jira)
• [jira] [Closed] (FLINK-38291) Reduce thread lock overhead for Flink UI REST handlers Xuannan Su (Jira)
• Re: [PR] [FLINK-37739][cli] fix flink-conf is not obtained in local mode [flink-cdc] via GitHub
• [jira] [Commented] (FLINK-38270) MySQL CDC source may ignore newly added tables while reading the binlog (scenario 2) Sergei Morozov (Jira)
  • [jira] [Commented] (FLINK-38270) MySQL CDC source may ignore newly added tables while reading the binlog (scenario 2) Sergei Morozov (Jira)
  • [jira] [Commented] (FLINK-38270) MySQL CDC source may ignore newly added tables while reading the binlog (scenario 2) Hongshun Wang (Jira)
• [jira] [Updated] (FLINK-38270) MySQL CDC source may ignore newly added tables while reading the binlog (scenario 2) Sergei Morozov (Jira)
  • [jira] [Updated] (FLINK-38270) MySQL CDC source may ignore newly added tables while reading the binlog (scenario 2) Sergei Morozov (Jira)
  • [jira] [Updated] (FLINK-38270) MySQL CDC source may ignore newly added tables while reading the binlog (scenario 2) Sergei Morozov (Jira)
• [jira] [Created] (FLINK-38323) Global Scale Factor Mode Salva (Jira)
• [jira] [Created] (FLINK-38321) Optimize the timer registration logic n window early/late firing scenarios Jacky Lau (Jira)
• [PR] [FLINK-38321][table] Optimize the timer registration logic n window e… [flink] via GitHub
  • Re: [PR] [FLINK-38321][table] Optimize the timer registration logic in window e… [flink] via GitHub
  • Re: [PR] [FLINK-38321][table] Optimize the timer registration logic n window e… [flink] via GitHub
• [D] Vector Store Integration for Flink Agents [flink-agents] via GitHub
  • Re: [D] Vector Store Integration for Flink Agents [flink-agents] via GitHub
  • Re: [D] Vector Store Integration for Flink Agents [flink-agents] via GitHub
  • Re: [D] Vector Store Integration for Flink Agents [flink-agents] via GitHub
  • Re: [D] Vector Store Integration for Flink Agents [flink-agents] via GitHub
  • Re: [D] Vector Store Integration for Flink Agents [flink-agents] via GitHub
  • Re: [D] Vector Store Integration for Flink Agents [flink-agents] via GitHub
  • Re: [D] Vector Store Integration for Flink Agents [flink-agents] via GitHub
  • Re: [D] Vector Store Integration for Flink Agents [flink-agents] via GitHub
  • Re: [D] Vector Store and Embedding Model Integration for Flink Agents [flink-agents] via GitHub
  • Re: [D] Vector Store and Embedding Model Integration for Flink Agents [flink-agents] via GitHub
• [jira] [Updated] (FLINK-38322) Update to Kafka Client 4.1.0 ASF GitHub Bot (Jira)
• Re: [PR] [FLINK-38229][runtime-web] Enhanced Job History Retention Policies for HistoryServer [flink] via GitHub
  • Re: [PR] [FLINK-38229][runtime-web] Enhanced Job History Retention Policies for HistoryServer [flink] via GitHub
  • Re: [PR] [FLINK-38229][runtime-web] Enhanced Job History Retention Policies for HistoryServer [flink] via GitHub
  • Re: [PR] [FLINK-38229][runtime-web] Enhanced Job History Retention Policies for HistoryServer [flink] via GitHub
  • Re: [PR] [FLINK-38229][runtime-web] Enhanced Job History Retention Policies for HistoryServer [flink] via GitHub
  • Re: [PR] [FLINK-38229][runtime-web] Enhanced Job History Retention Policies for HistoryServer [flink] via GitHub
  • Re: [PR] [FLINK-38229][runtime-web] Enhanced Job History Retention Policies for HistoryServer [flink] via GitHub
  • Re: [PR] [FLINK-38229][runtime-web] Enhanced Job History Retention Policies for HistoryServer [flink] via GitHub
  • Re: [PR] [FLINK-38229][runtime-web] Enhanced Job History Retention Policies for HistoryServer [flink] via GitHub
  • Re: [PR] [FLINK-38229][runtime-web] Enhanced Job History Retention Policies for HistoryServer [flink] via GitHub
• [jira] [Created] (FLINK-38322) Update to Kafka Client 4.1.0 Thomas Cooper (Jira)
• [jira] [Created] (FLINK-38320) Upgrade Pekko to 1.2.0 Mate Czagany (Jira)
• Re: [PR] [FLINK-16080][docs-zh] Translate new DISTRIBUTED BY documentation into Chinese [flink] via GitHub
  • Re: [PR] [FLINK-16080][docs-zh] Translate new DISTRIBUTED BY documentation into Chinese [flink] via GitHub
  • Re: [PR] [FLINK-16080][docs-zh] Translate new DISTRIBUTED BY documentation into Chinese [flink] via GitHub
  • Re: [PR] [FLINK-16080][docs-zh] Translate new DISTRIBUTED BY documentation into Chinese [flink] via GitHub
  • Re: [PR] [FLINK-16080][docs-zh] Translate new DISTRIBUTED BY documentation into Chinese [flink] via GitHub
  • Re: [PR] [FLINK-16080][docs-zh] Translate new DISTRIBUTED BY documentation into Chinese [flink] via GitHub
• [jira] [Created] (FLINK-38325) Checkpoints are hanging and timing out frequently Lucas Borges (Jira)
• Re: [PR] [FLINK-38253] Allow usage of vertx/jdk/jetty/okhttp clients in fabric8 in flink-kubernetes [flink] via GitHub
  • Re: [PR] [FLINK-38253] Allow usage of vertx/jdk/jetty/okhttp clients in fabric8 in flink-kubernetes [flink] via GitHub
  • Re: [PR] [FLINK-38253] Allow usage of vertx/jdk/jetty/okhttp clients in fabric8 in flink-kubernetes [flink] via GitHub
• [jira] [Commented] (FLINK-38190) Support async function in Python DataStream API Andrew Otto (Jira)
  • [jira] [Commented] (FLINK-38190) Support async function in Python DataStream API Kaiqi Dong (Jira)
  • [jira] [Commented] (FLINK-38190) Support async function in Python DataStream API Dian Fu (Jira)
• [jira] [Created] (FLINK-38324) Job fails to restore keyed state backend when using Forst state backend on S3 Lucas Borges (Jira)
• [jira] [Comment Edited] (FLINK-38323) Global Scale Factor Mode Salva (Jira)
  • [jira] [Comment Edited] (FLINK-38323) Global Scale Factor Mode Salva (Jira)
  • [jira] [Comment Edited] (FLINK-38323) Global Scale Factor Mode Salva (Jira)
  • [jira] [Comment Edited] (FLINK-38323) Global Scale Factor Mode Salva (Jira)
  • [jira] [Comment Edited] (FLINK-38323) Global Scale Factor Mode Salva (Jira)
• [jira] [Updated] (FLINK-38323) Global Scale Factor Mode Salva (Jira)
  • [jira] [Updated] (FLINK-38323) Global Scale Factor Mode Salva (Jira)
  • [jira] [Updated] (FLINK-38323) Global Scale Factor Mode Salva (Jira)
  • [jira] [Updated] (FLINK-38323) Global Scale Factor Mode Salva (Jira)
  • [jira] [Updated] (FLINK-38323) Global Scale Factor Mode Salva (Jira)
  • [jira] [Updated] (FLINK-38323) Global Scale Factor Mode Salva (Jira)
• [jira] [Commented] (FLINK-38323) Global Scale Factor Mode Gyula Fora (Jira)
  • [jira] [Commented] (FLINK-38323) Global Scale Factor Mode Salva (Jira)
  • [jira] [Commented] (FLINK-38323) Global Scale Factor Mode Gyula Fora (Jira)
  • [jira] [Commented] (FLINK-38323) Global Scale Factor Mode Salva (Jira)
• [PR] [FLINK-38322] Update to Kafka client 4.1.0 [flink-connector-kafka] via GitHub
• [PR] [hotfix] Fix tongyi chat model test failure. [flink-agents] via GitHub
  • Re: [PR] [hotfix] Fix tongyi chat model test failure. [flink-agents] via GitHub
• Re: [PR] [api][python] mcp definition and interfaces [flink-agents] via GitHub
  • Re: [PR] [api][python] mcp definition and interfaces [flink-agents] via GitHub
  • Re: [PR] [api][python] mcp definition and interfaces [flink-agents] via GitHub
  • Re: [PR] [api][python] mcp definition and interfaces [flink-agents] via GitHub
  • Re: [PR] [api][python] mcp definition and interfaces [flink-agents] via GitHub
  • Re: [PR] [api][python] mcp definition and interfaces [flink-agents] via GitHub
  • Re: [PR] [api][python] mcp definition and interfaces [flink-agents] via GitHub
  • Re: [PR] [api][python] mcp definition and interfaces [flink-agents] via GitHub
  • Re: [PR] [api][python] mcp definition and interfaces [flink-agents] via GitHub
  • Re: [PR] [api][python] mcp definition and interfaces [flink-agents] via GitHub
  • Re: [PR] [api][python] mcp definition and interfaces [flink-agents] via GitHub
• [jira] [Created] (FLINK-38319) TO_TIMESTAMP_LTZ only accepts literal values in PyFlink Dian Fu (Jira)
• [jira] [Updated] (FLINK-38318) Add python autoformatter to pyflink Sergey Nuyanzin (Jira)
  • [jira] [Updated] (FLINK-38318) Add python autoformatter to pyflink Sergey Nuyanzin (Jira)
  • [jira] [Updated] (FLINK-38318) Add python autoformatter to pyflink Sergey Nuyanzin (Jira)
  • [jira] [Updated] (FLINK-38318) Add python autoformatter to pyflink Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38318) Add python autoformatter to pyflink Sergey Nuyanzin (Jira)
• [jira] [Comment Edited] (FLINK-38270) MySQL CDC source may ignore newly added tables while reading the binlog (scenario 2) Hongshun Wang (Jira)
  • [jira] [Comment Edited] (FLINK-38270) MySQL CDC source may ignore newly added tables while reading the binlog (scenario 2) Hongshun Wang (Jira)
• [PR] [hotfix] Fix ollama chat model test failure. [flink-agents] via GitHub
  • Re: [PR] [hotfix] Fix ollama chat model test failure. [flink-agents] via GitHub
• [jira] [Created] (FLINK-38317) PushCalcPastChangelogNormalizeRule fails in case of partial push down and trimmed fields Sergey Nuyanzin (Jira)
• [jira] [Updated] (FLINK-38317) PushCalcPastChangelogNormalizeRule fails in case of partial push down and trimmed fields ASF GitHub Bot (Jira)
• [jira] [Resolved] (FLINK-38312) Add support for SHOW CREATE MATERIALIZED TABLES Sergey Nuyanzin (Jira)
• Re: [PR] [FLINK-37332] Support any column as chunk key column (postgres, orcale, db2, sqlserver) #3922 [flink-cdc] via GitHub
• [PR] Backport of https://github.com/apache/flink/pull/26518 [flink] via GitHub
  • Re: [PR] Backport of https://github.com/apache/flink/pull/26518 [flink] via GitHub
  • Re: [PR] Backport of https://github.com/apache/flink/pull/26518 [flink] via GitHub
• [PR] [WIP][FLINK-XXX][table] potential fix for PushCalcPastChangelogNormalizeRule [flink] via GitHub
  • Re: [PR] [WIP][FLINK-XXX][table] potential fix for PushCalcPastChangelogNormalizeRule [flink] via GitHub
  • Re: [PR] [FLINK-38317][table] PushCalcPastChangelogNormalizeRule fails in case of partial push down and trimmed fields [flink] via GitHub
  • Re: [PR] [FLINK-38317][table] PushCalcPastChangelogNormalizeRule fails in case of partial push down and trimmed fields [flink] via GitHub
• Re: [PR] [BP-2.0][FLINK-37747][runtime] Use old subtask count for restored committable… [flink] via GitHub
  • Re: [PR] [BP-2.0][FLINK-37747][runtime] Use old subtask count for restored committable… [flink] via GitHub
  • Re: [PR] [BP-2.0][FLINK-37747][runtime] Use old subtask count for restored committable… [flink] via GitHub
  • Re: [PR] [BP-2.0][FLINK-37747][runtime] Use old subtask count for restored committable… [flink] via GitHub
  • Re: [PR] [BP-2.0][FLINK-37747][runtime] Use old subtask count for restored committable… [flink] via GitHub
  • Re: [PR] [BP-2.0][FLINK-37747][runtime] Use old subtask count for restored committable… [flink] via GitHub
  • Re: [PR] [BP-2.0][FLINK-37747][runtime] Use old subtask count for restored committable… [flink] via GitHub
  • Re: [PR] [BP-2.0][FLINK-37747][runtime] Use old subtask count for restored committable… [flink] via GitHub
  • Re: [PR] [BP-2.0][FLINK-37747][runtime] Use old subtask count for restored committable… [flink] via GitHub
  • Re: [PR] [BP-2.0][FLINK-37747][runtime] Use old subtask count for restored committable… [flink] via GitHub
• Re: [PR] [FLINK-38180][task] Clean up task after switching to FAILED [flink] via GitHub
  • Re: [PR] [FLINK-38180][task] Clean up task after switching to FAILED [flink] via GitHub
• [PR] [Flink-38277] [postgres]drop slot when startup.mode=snapshot [flink-cdc] via GitHub
  • Re: [PR] [Flink-38277] [postgres]drop slot when startup.mode=snapshot [flink-cdc] via GitHub
  • Re: [PR] [Flink-38277] [postgres]drop slot when startup.mode=snapshot [flink-cdc] via GitHub
  • Re: [PR] [Flink-38277] [postgres]drop slot when startup.mode=snapshot [flink-cdc] via GitHub
  • Re: [PR] [Flink-38277] [postgres]drop slot when startup.mode=snapshot [flink-cdc] via GitHub
  • Re: [PR] [Flink-38277] [postgres]drop slot when startup.mode=snapshot [flink-cdc] via GitHub
  • Re: [PR] [Flink-38277] [postgres]drop slot when startup.mode=snapshot [flink-cdc] via GitHub
  • Re: [PR] [Flink-38277] [postgres]drop slot when startup.mode=snapshot [flink-cdc] via GitHub
  • Re: [PR] [Flink-38277] [postgres]drop slot when startup.mode=snapshot [flink-cdc] via GitHub
• [jira] [Created] (FLINK-38316) Clarify on some of the names in the source Marton Greber (Jira)
• [jira] [Updated] (FLINK-38312) Add support for SHOW CREATE MATERIALIZED TABLES ASF GitHub Bot (Jira)
• [PR] [build] Improve the building process to favor uv and pyproject [flink-agents] via GitHub
  • Re: [PR] [build] Improve the building process to favor uv and pyproject [flink-agents] via GitHub
• Re: [PR] [FLINK-37937] Test Cassandra source in real cluster conditions to better test the split [flink-connector-cassandra] via GitHub
  • Re: [PR] [FLINK-37937] Test Cassandra source in real cluster conditions to better test the split [flink-connector-cassandra] via GitHub
  • Re: [PR] [FLINK-37937] Test Cassandra source in real cluster conditions to better test the split [flink-connector-cassandra] via GitHub
  • Re: [PR] [FLINK-37937] Test Cassandra source in real cluster conditions to better test the split [flink-connector-cassandra] via GitHub
  • Re: [PR] [FLINK-37937] Test Cassandra source in real cluster conditions to better test the split [flink-connector-cassandra] via GitHub
  • Re: [PR] [FLINK-37937] Test Cassandra source in real cluster conditions to better test the split [flink-connector-cassandra] via GitHub
  • Re: [PR] [FLINK-37937] Test Cassandra source in real cluster conditions to better test the split [flink-connector-cassandra] via GitHub
  • Re: [PR] [FLINK-37937] Test Cassandra source in real cluster conditions to better test the split [flink-connector-cassandra] via GitHub
  • Re: [PR] [FLINK-37937] Test Cassandra source in real cluster conditions to better test the split [flink-connector-cassandra] via GitHub
  • Re: [PR] [FLINK-37937] Test Cassandra source in real cluster conditions to better test the split [flink-connector-cassandra] via GitHub
  • Re: [PR] [FLINK-37937] Test Cassandra source in real cluster conditions to better test the split [flink-connector-cassandra] via GitHub
  • Re: [PR] [FLINK-37937] Test Cassandra source in real cluster conditions to better test the split [flink-connector-cassandra] via GitHub
  • Re: [PR] [FLINK-37937] Test Cassandra source in real cluster conditions to better test the split [flink-connector-cassandra] via GitHub
  • Re: [PR] [FLINK-37937] Test Cassandra source in real cluster conditions to better test the split [flink-connector-cassandra] via GitHub
  • Re: [PR] [FLINK-37937] Test Cassandra source in real cluster conditions to better test the split [flink-connector-cassandra] via GitHub
  • Re: [PR] [FLINK-37937] Test Cassandra source in real cluster conditions to better test the split [flink-connector-cassandra] via GitHub
  • Re: [PR] [FLINK-37937] Test Cassandra source in real cluster conditions to better test the split [flink-connector-cassandra] via GitHub
  • Re: [PR] [FLINK-37937] Test Cassandra source in real cluster conditions to better test the split [flink-connector-cassandra] via GitHub
  • Re: [PR] [FLINK-37937] Test Cassandra source in real cluster conditions to better test the split [flink-connector-cassandra] via GitHub
  • Re: [PR] [FLINK-37937] Test Cassandra source in real cluster conditions to better test the split [flink-connector-cassandra] via GitHub
  • Re: [PR] [FLINK-37937] Test Cassandra source in real cluster conditions to better test the split [flink-connector-cassandra] via GitHub
  • Re: [PR] [FLINK-37937] Test Cassandra source in real cluster conditions to better test the split [flink-connector-cassandra] via GitHub
  • Re: [PR] [FLINK-37937] Test Cassandra source in real cluster conditions to better test the split [flink-connector-cassandra] via GitHub
  • Re: [PR] [FLINK-37937] Test Cassandra source in real cluster conditions to better test the split [flink-connector-cassandra] via GitHub
  • Re: [PR] [FLINK-37937] Test Cassandra source in real cluster conditions to better test the split [flink-connector-cassandra] via GitHub
  • Re: [PR] [FLINK-37937] Test Cassandra source in real cluster conditions to better test the split [flink-connector-cassandra] via GitHub
  • Re: [PR] [FLINK-37937] Test Cassandra source in real cluster conditions to better test the split [flink-connector-cassandra] via GitHub
  • Re: [PR] [FLINK-37937] Test Cassandra source in real cluster conditions to better test the split [flink-connector-cassandra] via GitHub
  • Re: [PR] [FLINK-37937] Test Cassandra source in real cluster conditions to better test the split [flink-connector-cassandra] via GitHub
  • Re: [PR] [FLINK-37937] Test Cassandra source in real cluster conditions to better test the split [flink-connector-cassandra] via GitHub
  • Re: [PR] [FLINK-37937] Test Cassandra source in real cluster conditions to better test the split [flink-connector-cassandra] via GitHub
  • Re: [PR] [FLINK-37937] Test Cassandra source in real cluster conditions to better test the split [flink-connector-cassandra] via GitHub
  • Re: [PR] [FLINK-37937] Test Cassandra source in real cluster conditions to better test the split [flink-connector-cassandra] via GitHub
  • Re: [PR] [FLINK-37937] Test Cassandra source in real cluster conditions to better test the split [flink-connector-cassandra] via GitHub
  • Re: [PR] [FLINK-37937] Test Cassandra source in real cluster conditions to better test the split [flink-connector-cassandra] via GitHub
• Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] via GitHub
  • Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] via GitHub
  • Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] via GitHub
  • Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] via GitHub
  • Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] via GitHub
  • Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] via GitHub
  • Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] via GitHub
  • Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] via GitHub
  • Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] via GitHub
  • Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] via GitHub
  • Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] via GitHub
  • Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] via GitHub
  • Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] via GitHub
  • Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] via GitHub
  • Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] via GitHub
  • Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] via GitHub
  • Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] via GitHub
  • Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] via GitHub
  • Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra] via GitHub

• Earlier messages
• Later messages