issues  

Messages by Thread

• • [jira] [Updated] (FLINK-38370) CommitterOperator does not checkpoint all pending committables Maximilian Michels (Jira)
  • [jira] [Updated] (FLINK-38370) CommitterOperator does not checkpoint all pending committables Xuannan Su (Jira)
  • [jira] [Updated] (FLINK-38370) CommitterOperator does not checkpoint all pending committables Maximilian Michels (Jira)
  • [jira] [Updated] (FLINK-38370) CommitterOperator does not checkpoint all pending committables Xuannan Su (Jira)
  • [jira] [Updated] (FLINK-38370) CommitterOperator does not checkpoint all pending committables ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-38370) CommitterOperator does not checkpoint all pending committables Gabor Somogyi (Jira)
• [jira] [Closed] (FLINK-37295) Update state ttl migration compatibility in docs Gabor Somogyi (Jira)
• [jira] [Created] (FLINK-38369) RestClientTest failed in test_cron_hadoop313 core Ruan Hang (Jira)
• [PR] Add partitioned async deserialization with ordered emission [flink-cdc] via GitHub
  • Re: [PR] Add partitioned async deserialization with ordered emission [flink-cdc] via GitHub
• Re: [PR] [FLINK-35936][cdc-connector][paimon] Fix paimon cdc schema evolution failure when restart job [flink-cdc] via GitHub
  • Re: [PR] [FLINK-35936][cdc-connector][paimon] Fix paimon cdc schema evolution failure when restart job [flink-cdc] via GitHub
  • Re: [PR] [FLINK-35936][cdc-connector][paimon] Fix paimon cdc schema evolution failure when restart job [flink-cdc] via GitHub
• Re: [PR] [FLINK-36631] add oracle read data by specific offset [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36631] add oracle read data by specific offset [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36631] add oracle read data by specific offset [flink-cdc] via GitHub
• Re: [PR] [minor][improvement] Add subdirectory scrapping to add all .jar in classpath [flink-cdc] via GitHub
  • Re: [PR] [minor][improvement] Add subdirectory scrapping to add all .jar in classpath [flink-cdc] via GitHub
  • Re: [PR] [minor][improvement] Add subdirectory scrapping to add all .jar in classpath [flink-cdc] via GitHub
• Re: [PR] [FLINK-31215] [autoscaler] Backpropagate processing rate limits from non-scalable bottlenecks to upstream operators [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-31215] [autoscaler] Backpropagate processing rate limits from non-scalable bottlenecks to upstream operators [flink-kubernetes-operator] via GitHub
• Re: [PR] Simple test PR [flink-kubernetes-operator] via GitHub
• [jira] [Resolved] (FLINK-38359) Avoid writing Record with update before/delete rowKind to Paimon append only table. Yanquan Lv (Jira)
• [jira] [Resolved] (FLINK-38358) Ignore trailing spaces in table capturing rules Yanquan Lv (Jira)
• Re: [PR] [FLINK-36178][pipeline-connector/mysql] Parse `CREATE TABLE ... LIKE …` syntax. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36178][pipeline-connector/mysql] Parse `CREATE TABLE ... LIKE …` syntax. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36178][pipeline-connector/mysql] Parse `CREATE TABLE ... LIKE …` syntax. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36178][pipeline-connector/mysql] Parse `CREATE TABLE ... LIKE …` syntax. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36178][pipeline-connector/mysql] Parse `CREATE TABLE ... LIKE …` syntax. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36178][pipeline-connector/mysql] Parse `CREATE TABLE ... LIKE …` syntax. [flink-cdc] via GitHub
• [PR] [api] Add TaskActionState API to persist task action state [flink-agents] via GitHub
  • Re: [PR] [api] Add TaskActionState API to persist task action state [flink-agents] via GitHub
  • Re: [PR] [Feature] Implemenet Kafka-based state store [flink-agents] via GitHub
  • Re: [PR] [Feature] Implemenet Kafka-based state store [flink-agents] via GitHub
  • Re: [PR] [Feature] Implemenet Kafka-based state store [flink-agents] via GitHub
  • Re: [PR] [Feature] Implemenet Kafka-based state store [flink-agents] via GitHub
  • Re: [PR] [Feature] Implemenet Kafka-based state store [flink-agents] via GitHub
  • Re: [PR] [Feature] Implemenet Kafka-based state store [flink-agents] via GitHub
  • Re: [PR] [Feature] Implemenet Kafka-based state store [flink-agents] via GitHub
• [PR] [FLINK-38332][python] Bump pemja to 0.5.5 [flink] via GitHub
  • Re: [PR] [FLINK-38332][python] Bump pemja to 0.5.5 [flink] via GitHub
  • Re: [PR] [FLINK-38332][python] Bump pemja to 0.5.5 [flink] via GitHub
  • [PR] [FLINK-38332][python] Bump pemja to 0.5.5 [flink] via GitHub
  • Re: [PR] [FLINK-38332][python] Bump pemja to 0.5.5 [flink] via GitHub
  • Re: [PR] [FLINK-38332][python] Bump pemja to 0.5.5 [flink] via GitHub
  • [PR] [FLINK-38332][python] Bump pemja to 0.5.5 [flink] via GitHub
  • Re: [PR] [FLINK-38332][python] Bump pemja to 0.5.5 [flink] via GitHub
  • Re: [PR] [FLINK-38332][python] Bump pemja to 0.5.5 [flink] via GitHub
• [D] Flink Agent Project Docs [flink-agents] via GitHub
  • Re: [D] Flink Agent Project Docs [flink-agents] via GitHub
  • Re: [D] Flink Agent Project Docs [flink-agents] via GitHub
  • Re: [D] Flink Agent Project Docs [flink-agents] via GitHub
  • Re: [D] Flink Agent Project Docs [flink-agents] via GitHub
  • Re: [D] Flink Agent Project Docs [flink-agents] via GitHub
  • Re: [D] Flink Agent Project Docs [flink-agents] via GitHub
  • Re: [D] Flink Agent Project Docs [flink-agents] via GitHub
  • Re: [D] Flink Agent Project Docs [flink-agents] via GitHub
  • Re: [D] Flink Agent Project Docs [flink-agents] via GitHub
  • Re: [D] Flink Agent Project Docs [flink-agents] via GitHub
  • Re: [D] Flink Agent Project Docs [flink-agents] via GitHub
• Re: [I] [Feature][api][java] Support interactive interface of Agent and AgentExecutionEnvironment. [flink-agents] via GitHub
• Re: [PR] [hotfix][postgres] PostgresSourceFetchTaskContext log do not output P… [flink-cdc] via GitHub
• Re: [PR] [api][java] Support interactive interface of Agent and AgentExecutionEnvironment. [flink-agents] via GitHub
• Re: [PR] [FLINK-38358][pipeline-connector][mysql] Ignore trailing spaces in table capturing rules. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38358][pipeline-connector][mysql] Ignore trailing spaces in table capturing rules. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38358][pipeline-connector][mysql] Ignore trailing spaces in table capturing rules. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38358][pipeline-connector][mysql] Ignore trailing spaces in table capturing rules. [flink-cdc] via GitHub
• [jira] [Updated] (FLINK-38358) Ignore trailing spaces in table capturing rules ASF GitHub Bot (Jira)
• [PR] Fix CI and upgrade to use Flink 1.18.1 [flink-connector-pulsar] via GitHub
  • Re: [PR] Fix CI and upgrade to use Flink 1.18.1 [flink-connector-pulsar] via GitHub
• [jira] [Updated] (FLINK-38313) Add support for DISTRIBUTION in MATERIALIZED TABLES Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38368) Potential Feedback Loop Involving a Heavy User Defined Aggregation Task Shangshu Qian (Jira)
• [jira] [Commented] (FLINK-38313) Add support for DISTRIBUTION in MATERIALIZED TABLES Sergey Nuyanzin (Jira)
• [jira] [Commented] (FLINK-38365) ClassCastException while different operations with MATERIALIZED TABLE Sergey Nuyanzin (Jira)
• [jira] [Resolved] (FLINK-38365) ClassCastException while different operations with MATERIALIZED TABLE Sergey Nuyanzin (Jira)
• [jira] [Updated] (FLINK-38366) Pyflink planner throws exception in batch mode when there is no limit on order_by() Ahmad Humayun (Jira)
  • [jira] [Updated] (FLINK-38366) Pyflink planner throws exception in batch mode when there is no limit on order_by() Ahmad Humayun (Jira)
  • [jira] [Updated] (FLINK-38366) Pyflink planner throws exception in batch mode when there is no limit on order_by() Ahmad Humayun (Jira)
• [jira] [Created] (FLINK-38366) Pyflink planner throws exception in batch mode when there is no limit on order_by() Ahmad Humayun (Jira)
• [jira] [Created] (FLINK-38363) WindowedStream.trigger supports trigger with async state Zakelly Lan (Jira)
• [PR] [hotfix] Pin rsync by hash to allow docs to be build [flink] via GitHub
  • Re: [PR] [hotfix] Pin rsync by hash to allow docs to be build [flink] via GitHub
  • Re: [PR] [hotfix] Pin rsync by hash to allow docs to be build [flink] via GitHub
• [jira] [Resolved] (FLINK-37979) Obsolete MySQL CDC snapshot split assigner code Yanquan Lv (Jira)
• [jira] [Updated] (FLINK-37979) Obsolete MySQL CDC snapshot split assigner code ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-38362) Reduce the time cost in checkpoint when writing many tables to StarRocks sink Yanquan Lv (Jira)
• [jira] [Assigned] (FLINK-38359) Avoid writing Record with update before/delete rowKind to Paimon append only table. Yanquan Lv (Jira)
• [jira] [Resolved] (FLINK-38265) Stream Split shouldn't finish when exception occors Yanquan Lv (Jira)
• Re: [PR] [FLINK-38311][table] Add support for distribution by for materialized tables [flink] via GitHub
  • Re: [PR] [FLINK-38311][table] Add support for distribution by for materialized tables [flink] via GitHub
  • Re: [PR] [FLINK-38311][table] Add support for distribution by for materialized tables [flink] via GitHub
  • Re: [PR] [FLINK-38311][table] Add support for distribution by for materialized tables [flink] via GitHub
  • Re: [PR] [FLINK-38311][table] Add support for distribution by for materialized tables [flink] via GitHub
  • Re: [PR] [FLINK-38311][table] Add support for distribution by for materialized tables [flink] via GitHub
• Re: [PR] [Feature] [integration][python] OpenAI embedding model integration [flink-agents] via GitHub
  • Re: [PR] [Feature] [integration][python] OpenAI embedding model integration [flink-agents] via GitHub
• [jira] [Closed] (FLINK-38352) Expose timestamp used in DefaultWatermarkGenerator Timo Walther (Jira)
• Re: [PR] [FLINK-38352][table] Expose timestamp used in DefaultWatermarkGenerator [flink] via GitHub
• [jira] [Updated] (FLINK-38352) Expose timestamp used in DefaultWatermarkGenerator ASF GitHub Bot (Jira)
• [I] [Feature][examples] Showcase Table API in the quickstart example [flink-agents] via GitHub
• [I] [Feature] ActionExecutionOperator handle watermark properly [flink-agents] via GitHub
  • Re: [I] [Feature] ActionExecutionOperator handle watermark properly [flink-agents] via GitHub
• Re: [PR] [FLINK-37697][Documentation] Adding Confluent to vendors list [flink] via GitHub
  • Re: [PR] [FLINK-37697][Documentation] Adding Confluent to vendors list [flink] via GitHub
  • Re: [PR] [FLINK-37697][Documentation] Adding Confluent to vendors list [flink] via GitHub
• [PR] [Feature] Unify the name of ResourceProvider and Resource [flink-agents] via GitHub
  • Re: [PR] [Feature] Unify the name of ResourceProvider and Resource [flink-agents] via GitHub
  • Re: [PR] [Feature] Unify the name of ResourceProvider and Resource [flink-agents] via GitHub
  • Re: [PR] [Feature] Unify the name of ResourceProvider and Resource [flink-agents] via GitHub
  • Re: [PR] [Feature] Remove the name field of Resource [flink-agents] via GitHub
  • Re: [PR] [Feature] Remove the name field of Resource [flink-agents] via GitHub
  • Re: [PR] [Feature] Remove the name field of Resource [flink-agents] via GitHub
  • Re: [PR] [Feature] Remove the name field of Resource [flink-agents] via GitHub
  • Re: [PR] [Feature] Remove the name field of Resource [flink-agents] via GitHub
• Re: [PR] [docs] Adding Confluent to vendors list [flink] via GitHub
• [jira] [Resolved] (FLINK-26823) Make Cassandra Source available for Flink SQL users Etienne Chauchot (Jira)
• [jira] [Updated] (FLINK-38359) Avoid writing Record with update before/delete rowKind to Paimon append only table. ASF GitHub Bot (Jira)
• [PR] [FLINK-38359][pipeline-connector][paimon] Avoid exception when writing update event to Append only table. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38359][pipeline-connector][paimon] Avoid exception when writing update event to Append only table. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38359][pipeline-connector][paimon] Avoid exception when writing update event to Append only table. [flink-cdc] via GitHub
• [jira] [Commented] (FLINK-38359) Avoid writing Record with update before/delete rowKind to Paimon append only table. Yanquan Lv (Jira)
• [jira] [Created] (FLINK-38359) Avoid writing Record with update before/delete rowKind to Paimon append only table. Yanquan Lv (Jira)
• [jira] [Created] (FLINK-38360) HadoopRecoverableWriterTest failed in test_cron_adaptive_scheduler connect Ruan Hang (Jira)
• [jira] [Commented] (FLINK-38358) Ignore trailing spaces in table capturing rules Yanquan Lv (Jira)
• [jira] [Assigned] (FLINK-38268) Incorrect serialization of VARIANT type FLOAT Timo Walther (Jira)
• [jira] [Created] (FLINK-38361) ChangelogRecoverySwitchStateBackendITCase failed in test_ci tests Ruan Hang (Jira)
• [jira] [Assigned] (FLINK-38358) Ignore trailing spaces in table capturing rules Yanquan Lv (Jira)
• [jira] [Updated] (FLINK-38332) Upgrade pemja to 0.5.5 Xuannan Su (Jira)
  • [jira] [Updated] (FLINK-38332) Upgrade pemja to 0.5.5 Dian Fu (Jira)
• [jira] [Created] (FLINK-38358) Ignore trailing spaces in table capturing rules Yanquan Lv (Jira)
• [jira] [Resolved] (FLINK-36980) Build a new introductory practice "Streaming ELT from MySQL to Kafka" Yanquan Lv (Jira)
• [jira] [Resolved] (FLINK-37479) postgres cdc connector support discover PARTITIONED TABLE Yanquan Lv (Jira)
• [jira] [Resolved] (FLINK-38310) Binary keys in a FinishedSnapshotSplitInfo are incorrectly compared and hashed Yanquan Lv (Jira)
• [jira] [Assigned] (FLINK-38310) Binary keys in a FinishedSnapshotSplitInfo are incorrectly compared and hashed Yanquan Lv (Jira)
• [PR] Simple change to merge and help run automated tests afterwards [flink-kubernetes-operator] via GitHub
  • Re: [PR] Fixing typos in README.md files [flink-kubernetes-operator] via GitHub
• [jira] [Commented] (FLINK-38350) Update Hadoop Library to 3.4.2 Thomas Cooper (Jira)
  • [jira] [Commented] (FLINK-38350) Update Hadoop Library to 3.4.2 Martijn Visser (Jira)
• [PR] now issue is resolved [flink] via GitHub
  • Re: [PR] now issue is resolved [flink] via GitHub
  • Re: [PR] now issue is resolved [flink] via GitHub
  • Re: [PR] now issue is resolved [flink] via GitHub
• [jira] [Closed] (FLINK-38356) Regenerating files for WATERMARK_ASSIGNER_PUSHDOWN_METADATA hangs Timo Walther (Jira)
• [jira] [Comment Edited] (FLINK-38350) Update Hadoop Library to 3.4.2 Thomas Cooper (Jira)
• [jira] [Updated] (FLINK-38357) ResultSubpartitionRecoveredStateHandler.getSubpartition ArrayIndexOutOfBoundException 0 Xinglong Wang (Jira)
  • [jira] [Updated] (FLINK-38357) ResultSubpartitionRecoveredStateHandler.getSubpartition ArrayIndexOutOfBoundException 0 Xinglong Wang (Jira)
  • [jira] [Updated] (FLINK-38357) ResultSubpartitionRecoveredStateHandler.getSubpartition ArrayIndexOutOfBoundException 0 Xinglong Wang (Jira)
  • [jira] [Updated] (FLINK-38357) ResultSubpartitionRecoveredStateHandler.getSubpartition ArrayIndexOutOfBoundException 0 Xinglong Wang (Jira)
  • [jira] [Updated] (FLINK-38357) ResultSubpartitionRecoveredStateHandler.getSubpartition ArrayIndexOutOfBoundException 0 Xinglong Wang (Jira)
  • [jira] [Updated] (FLINK-38357) ResultSubpartitionRecoveredStateHandler.getSubpartition ArrayIndexOutOfBoundException 0 Xinglong Wang (Jira)
  • [jira] [Updated] (FLINK-38357) ResultSubpartitionRecoveredStateHandler.getSubpartition ArrayIndexOutOfBoundException 0 Xinglong Wang (Jira)
  • [jira] [Updated] (FLINK-38357) ResultSubpartitionRecoveredStateHandler.getSubpartition ArrayIndexOutOfBoundException 0 Xinglong Wang (Jira)
• [jira] [Created] (FLINK-38357) ResultSubpartitionRecoveredStateHandler.getSubpartition ArrayIndexOutOfBoundException 0 Xinglong Wang (Jira)
• [jira] [Updated] (FLINK-38356) Regenerating files for WATERMARK_ASSIGNER_PUSHDOWN_METADATA hangs ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-38356) Regenerating files for WATERMARK_ASSIGNER_PUSHDOWN_METADATA hangs Dawid Wysakowicz (Jira)
• [PR] [FLINK-38356] Respect terminating flag for test values source [flink] via GitHub
  • Re: [PR] [FLINK-38356] Respect terminating flag for test values source [flink] via GitHub
  • Re: [PR] [FLINK-38356] Respect terminating flag for test values source [flink] via GitHub
  • Re: [PR] [FLINK-38356] Respect terminating flag for test values source [flink] via GitHub
• [jira] [Assigned] (FLINK-38356) Regenerating files for WATERMARK_ASSIGNER_PUSHDOWN_METADATA hangs Dawid Wysakowicz (Jira)
• [PR] [docs] Update installation instructions for Flink Agents with PyPI and source build details [flink-agents] via GitHub
  • Re: [PR] [docs] Update installation instructions for Flink Agents with PyPI and source build details [flink-agents] via GitHub
  • Re: [PR] [docs] Update installation instructions for Flink Agents with PyPI and source build details [flink-agents] via GitHub
• [jira] [Closed] (FLINK-37936) Support hint based State-TTL for StreamingMultiJoinOperator Timo Walther (Jira)
• [PR] Mcp complete 1 [flink-agents] via GitHub
  • Re: [PR] [api][python] Add built-in mcp support [flink-agents] via GitHub
  • Re: [PR] [api][python] Add built-in mcp support [flink-agents] via GitHub
  • Re: [PR] [api][python] Add built-in mcp support [flink-agents] via GitHub
  • Re: [PR] [api][python] Add built-in mcp support [flink-agents] via GitHub
  • Re: [PR] [api][python] Add built-in mcp support [flink-agents] via GitHub
  • Re: [PR] [api][python] Add built-in mcp support [flink-agents] via GitHub
• [jira] [Updated] (FLINK-38355) [FLIP-546] Introduce CREATE OR ALTER Syntax for Materialized Tables Ramin Gharib (Jira)
• [jira] [Updated] (FLINK-38229) FLIP-490: Enhanced Job History Retention Policies for HistoryServer​ RocMarshal (Jira)
• [I] [Feature] [integration][python] OpenAI embedding model integration [flink-agents] via GitHub
  • Re: [I] [Feature] [integration][python] OpenAI embedding model integration [flink-agents] via GitHub
• [jira] [Resolved] (FLINK-37096) If the MongoDB connector is implemented with DebeziumSourceFunction, the curve will appear in the full phase delay curve showing 55year Yanquan Lv (Jira)
• [jira] [Updated] (FLINK-37096) If the MongoDB connector is implemented with DebeziumSourceFunction, the curve will appear in the full phase delay curve showing 55year Yanquan Lv (Jira)
• [PR] [api][python] support VectorStore and provide a built-in Chroma implementation [flink-agents] via GitHub
  • Re: [PR] [api][python] support VectorStore and provide a built-in Chroma implementation [flink-agents] via GitHub
  • Re: [PR] [api][python] support VectorStore and provide a built-in Chroma implementation [flink-agents] via GitHub
  • Re: [PR] [api][python] support VectorStore and provide a built-in Chroma implementation [flink-agents] via GitHub
  • Re: [PR] [api][python] support VectorStore and provide a built-in Chroma implementation [flink-agents] via GitHub
  • Re: [PR] [api][python] support VectorStore and provide a built-in Chroma implementation [flink-agents] via GitHub
  • Re: [PR] [api][python] support VectorStore and provide a built-in Chroma implementation [flink-agents] via GitHub
• [jira] [Assigned] (FLINK-37096) If the MongoDB connector is implemented with DebeziumSourceFunction, the curve will appear in the full phase delay curve showing 55year Yanquan Lv (Jira)
• [jira] [Comment Edited] (FLINK-30975) Enable AWS SDK V2 Support for Flink's S3 FileSystem Modules Samrat Deb (Jira)
• [jira] [Created] (FLINK-38354) ClassCastException occurs when submitting a task to flink cdc hunter (Jira)
• [jira] [Assigned] (FLINK-38247) MySqlChunkSplitter may continuously generate splits when using BIGINT UNSIGNED as primary key Yanquan Lv (Jira)
• [jira] [Commented] (FLINK-38247) MySqlChunkSplitter may continuously generate splits when using BIGINT UNSIGNED as primary key Yanquan Lv (Jira)
• [jira] [Updated] (FLINK-38319) TO_TIMESTAMP_LTZ only accepts literal values in PyFlink ASF GitHub Bot (Jira)
• [PR] [FLINK-38319] Allow TO_TIMESTAMP_LTZ to accept expression in PyFlink [flink] via GitHub
  • Re: [PR] [FLINK-38319][python] Allow TO_TIMESTAMP_LTZ to accept expression in PyFlink [flink] via GitHub
  • Re: [PR] [FLINK-38319][python] Allow TO_TIMESTAMP_LTZ to accept expression in PyFlink [flink] via GitHub
  • Re: [PR] [FLINK-38319][python] Allow TO_TIMESTAMP_LTZ to accept expression in PyFlink [flink] via GitHub
  • Re: [PR] [FLINK-38319][python] Allow TO_TIMESTAMP_LTZ to accept expression in PyFlink [flink] via GitHub
  • Re: [PR] [FLINK-38319][python] Allow TO_TIMESTAMP_LTZ to accept expression in PyFlink [flink] via GitHub
  • Re: [PR] [FLINK-38319][python] Allow TO_TIMESTAMP_LTZ to accept expression in PyFlink [flink] via GitHub
  • Re: [PR] [FLINK-38319][python] Allow TO_TIMESTAMP_LTZ to accept expression in PyFlink [flink] via GitHub
• [PR] Reuse byte array buffer in BlobServerConnection::run [flink] via GitHub
  • Re: [PR] Reuse byte array buffer in BlobServerConnection::run [flink] via GitHub

• Earlier messages
• Later messages