issues  

Messages by Thread

• [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)
• [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] [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
• [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
• [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-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
  • 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
  • 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
  • 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
• [jira] [Commented] (FLINK-38315) Performance regression since August 21 Ruan Hang (Jira)
  • [jira] [Commented] (FLINK-38315) Performance regression since August 21 Zakelly Lan (Jira)
• [jira] [Created] (FLINK-38315) Performance regression since August 21 Ruan Hang (Jira)
• [jira] [Assigned] (FLINK-38272) The BatchJobRecoveryTest failed of azure cron adaptive scheduler pipeline Ruan Hang (Jira)
• [jira] [Created] (FLINK-38310) Binary keys in a FinishedSnapshotSplitInfo are incorrectly compared and hashed Sergei Morozov (Jira)
• [PR] [FLINK-37200]Add e2e test for ElasticSearch Sink. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37200]Add e2e test for ElasticSearch Sink. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37200]Add e2e test for ElasticSearch Sink. [flink-cdc] via GitHub
• [jira] [Created] (FLINK-38308) Prevent excessive logging from parsing SQL timestamps/dates Roman Khachatryan (Jira)
• [jira] [Updated] (FLINK-38124) The autoscaling example misses README ASF GitHub Bot (Jira)
• Re: [PR] FLINK-37774: SQL Server CDC connector incorrectly handles special characters in database and table names [flink-cdc] via GitHub
• [jira] [Created] (FLINK-38311) FLIP-542: Make materialized table DDL consistent with regular tables Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38312) Add support for SHOW CREATE MATERIALIZED TABLES Sergey Nuyanzin (Jira)
• Re: [PR] [FLINK-37254] Add OceanBaseDefaultValueConverter to fix table schema validation [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37254] Add OceanBaseDefaultValueConverter to fix table schema validation [flink-cdc] via GitHub
• Re: [PR] [FLINK-36024][source-connector][mysql] Throw the exception encountered when searching for the starting binlog [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36024][source-connector][mysql] Throw the exception encountered when searching for the starting binlog [flink-cdc] via GitHub
• [PR] [FLINK-37300][common] Add RawDataType to represent the type in data sources [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37300][common] Add RawDataType to represent the type in data sources [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37300][common] Add RawDataType to represent the type in data sources [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37300][common] Add RawDataType to represent the type in data sources [flink-cdc] via GitHub
• [jira] [Created] (FLINK-38314) Flink dashboard incorrectly shows units for RocksDB `live-sst-files-size` metric for timer state Aleksandr Iushmanov (Jira)
• [jira] [Created] (FLINK-38313) Add support for DISTRIBUTION in MATERIALIZED TABLES Sergey Nuyanzin (Jira)
• [PR] [FLINK-38124][docs] Add README for Autoscaling example [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-38124][docs] Add README for Autoscaling example [flink-kubernetes-operator] via GitHub
• [PR] [FLINK-38312][table] Add support for `SHOW MATERIALIZED TABLES` [flink] via GitHub
  • Re: [PR] [FLINK-38312][table] Add support for `SHOW MATERIALIZED TABLES` [flink] via GitHub
  • Re: [PR] [FLINK-38312][table] Add support for `SHOW MATERIALIZED TABLES` [flink] via GitHub
  • Re: [PR] [FLINK-38312][table] Add support for `SHOW MATERIALIZED TABLES` [flink] via GitHub
  • Re: [PR] [FLINK-38312][table] Add support for `SHOW MATERIALIZED TABLES` [flink] via GitHub
  • Re: [PR] [FLINK-38312][table] Add support for `SHOW MATERIALIZED TABLES` [flink] via GitHub
  • Re: [PR] [FLINK-38312][table] Add support for `SHOW MATERIALIZED TABLES` [flink] via GitHub
  • Re: [PR] [FLINK-38312][table] Add support for `SHOW MATERIALIZED TABLES` [flink] via GitHub
• [jira] [Updated] (FLINK-38311) FLIP-542: Make materialized table DDL consistent with regular tables Sergey Nuyanzin (Jira)
  • [jira] [Updated] (FLINK-38311) FLIP-542: Make materialized table DDL consistent with regular tables ASF GitHub Bot (Jira)
• [PR] FLINK-38310: Fix handling binary boundaries in FinishedSnapshotSplitInfo [flink-cdc] via GitHub
• [jira] [Updated] (FLINK-38310) Binary keys in a FinishedSnapshotSplitInfo are incorrectly compared and hashed Sergei Morozov (Jira)

• Earlier messages
• Later messages