issues  

Messages by Date

• 2025/02/20 Re: [PR] [FLINK-37363][state] Removed confusing and duplicated state.backend.type config from state SQL connector [flink] via GitHub
• 2025/02/20 [PR] [FLINK-37363][state] Removed confusing and duplicated state.backend.type config from state SQL connector [flink] via GitHub
• 2025/02/20 [jira] [Commented] (FLINK-36900) Migrate away from Anaconda for managing Python environments for Flink Python Sergey Nuyanzin (Jira)
• 2025/02/20 [PR] [FLINK-37364][build] Bump Flink 1.19 and 1.20 patch versions [flink-cdc] via GitHub
• 2025/02/20 [jira] [Updated] (FLINK-37364) Bump Flink 1.19, 1.20 patch versions in Flink CDC ASF GitHub Bot (Jira)
• 2025/02/20 Re: [PR] [FLINK-37320] [Observer] FINISHED finite streaming jobs incorrectly being set to RECONCILING [flink-kubernetes-operator] via GitHub
• 2025/02/20 Re: [PR] [FLINK-36900] Migrate from conda to uv for managing Python environments [flink-connector-shared-utils] via GitHub
• 2025/02/20 Re: [PR] [FLINK-36900] Migrate from conda to uv for managing Python environments [flink-connector-shared-utils] via GitHub
• 2025/02/20 [jira] [Updated] (FLINK-31238) Use IngestDB to speed up Rocksdb rescaling recovery Gabor Somogyi (Jira)
• 2025/02/20 Re: [PR] [FLINK-37236] Bump the flink version from 1.20.0 to 1.20.1 [flink-kubernetes-operator] via GitHub
• 2025/02/20 Re: [PR] [FLINK-36409] Publish some autoscaler metrics during stabilisation period [flink-kubernetes-operator] via GitHub
• 2025/02/20 [jira] [Updated] (FLINK-37363) Remove confusing and duplicated state.backend.type config from state SQL connector Gabor Somogyi (Jira)
• 2025/02/20 [jira] [Created] (FLINK-37364) Bump Flink 1.19, 1.20 patch versions in Flink CDC Ferenc Csaky (Jira)
• 2025/02/20 Re: [PR] [FLINK-36594][hive]HiveCatalog should set HiveConf.hiveSiteLocation back [flink] via GitHub
• 2025/02/20 Re: [PR] [FLINK-36594][hive]HiveCatalog should set HiveConf.hiveSiteLocation back [flink] via GitHub
• 2025/02/20 Re: [PR] [FLINK-36900] Migrate from conda to uv for managing Python environments [flink-connector-shared-utils] via GitHub
• 2025/02/20 Re: [PR] [FLINK-37120][cdc-connector] Add ending split chunk first to avoid TaskManager oom [flink-cdc] via GitHub
• 2025/02/20 Re: [PR] [FLINK-37152][build] Update Flink version to 1.20 [flink-cdc] via GitHub
• 2025/02/20 [jira] [Closed] (FLINK-37359) Docker build fails for Kubernetes operator Gyula Fora (Jira)
• 2025/02/20 [jira] [Created] (FLINK-37363) Remove confusing and duplicated state.backend.type config from state SQL connector Gabor Somogyi (Jira)
• 2025/02/20 Re: [PR] [FLINK-37359] Pin qemu image to 7.0.0 [flink-kubernetes-operator] via GitHub
• 2025/02/20 [jira] [Created] (FLINK-37362) PolardbxCharsetITCase test has timed out after 60 minutes Leonard Xu (Jira)
• 2025/02/20 Re: [PR] [FLINK-37329][table-planner] Skip Source Stats Collection When table.optimizer.source.report-statistics-enabled is False [flink] via GitHub
• 2025/02/20 Re: [PR] [FLINK-37152][build] Update Flink version to 1.20 [flink-cdc] via GitHub
• 2025/02/20 [jira] [Updated] (FLINK-37152) Update Flink version to 1.20 in Flink CDC Leonard Xu (Jira)
• 2025/02/20 [jira] [Resolved] (FLINK-37152) Update Flink version to 1.20 in Flink CDC Leonard Xu (Jira)
• 2025/02/20 Re: [PR] [FLINK-37152][build] Update Flink version to 1.20 [flink-cdc] via GitHub
• 2025/02/20 Re: [PR] [FLINK-37152][build] Update Flink version to 1.20 [flink-cdc] via GitHub
• 2025/02/20 Re: [PR] [FLINK-37120][cdc-connector] Add ending split chunk first to avoid TaskManager oom [flink-cdc] via GitHub
• 2025/02/20 Re: [PR] [FLINK-37120][cdc-connector] Add ending split chunk first to avoid TaskManager oom [flink-cdc] via GitHub
• 2025/02/20 Re: [PR] [FLINK-37361][release] Update japicmp configuration post 1.19.2 [flink] via GitHub
• 2025/02/20 Re: [PR] [FLINK-37152][build] Update Flink version to 1.20 [flink-cdc] via GitHub
• 2025/02/20 Re: [PR] [FLINK-36900] Migrate from conda to uv for managing Python environments [flink-connector-shared-utils] via GitHub
• 2025/02/20 Re: [PR] [FLINK-37360][release] Update japicmp configuration post 1.20.1 [flink] via GitHub
• 2025/02/20 Re: [PR] [FLINK-37329][table-planner] Skip Source Stats Collection When table.optimizer.source.report-statistics-enabled is False [flink] via GitHub
• 2025/02/20 [PR] [FLINK-37360][release] Update japicmp configuration post 1.20.1 [flink] via GitHub
• 2025/02/20 Re: [PR] [FLINK-37152][build] Update Flink version to 1.20 [flink-cdc] via GitHub
• 2025/02/20 Re: [PR] [hotfix] Fix post-release japicmp update script for macOS [flink] via GitHub
• 2025/02/20 [jira] [Commented] (FLINK-37356) Recycle use of kafka producer(which commit error) maybe send data without AddPartitionsToTxnRequest Hongshun Wang (Jira)
• 2025/02/20 [jira] [Updated] (FLINK-37360) Update japicmp configuration post 1.20.1 ASF GitHub Bot (Jira)
• 2025/02/20 Re: [PR] [FLINK-37336][python] Introduce TablePipeline descriptor to Python Table API [flink] via GitHub
• 2025/02/20 [jira] [Updated] (FLINK-37361) Update japicmp configuration post 1.19.2 ASF GitHub Bot (Jira)
• 2025/02/20 Re: [PR] [FLINK-37336][python] Introduce TablePipeline descriptor to Python Table API [flink] via GitHub
• 2025/02/20 [jira] [Comment Edited] (FLINK-37356) Recycle use of kafka producer(which commit error) maybe send data without AddPartitionsToTxnRequest Hongshun Wang (Jira)
• 2025/02/20 [PR] [FLINK-37361][release] Update japicmp configuration post 1.19.2 [flink] via GitHub
• 2025/02/20 [jira] [Comment Edited] (FLINK-37356) Recycle use of kafka producer(which commit error) maybe send data without AddPartitionsToTxnRequest Hongshun Wang (Jira)
• 2025/02/20 Re: [PR] [FLINK-37336][python] Introduce TablePipeline descriptor to Python Table API [flink] via GitHub
• 2025/02/20 Re: [PR] [FLINK-37336][python] Introduce TablePipeline descriptor to Python Table API [flink] via GitHub
• 2025/02/20 [jira] [Updated] (FLINK-37361) Update japicmp configuration post 1.19.2 Alexander Fedulov (Jira)
• 2025/02/20 [jira] [Updated] (FLINK-37361) Update japicmp configuration post 1.19.2 Alexander Fedulov (Jira)
• 2025/02/20 [jira] [Updated] (FLINK-37360) Update japicmp configuration post 1.20.1 Alexander Fedulov (Jira)
• 2025/02/20 [jira] [Updated] (FLINK-37360) Update japicmp configuration post 1.20.1 Alexander Fedulov (Jira)
• 2025/02/20 [jira] [Created] (FLINK-37361) Update japicmp configuration post 1.19.2 Alexander Fedulov (Jira)
• 2025/02/20 [jira] [Updated] (FLINK-37361) Update japicmp configuration post 1.19.2 Alexander Fedulov (Jira)
• 2025/02/20 [jira] [Created] (FLINK-37360) Update japicmp configuration post 1.20.1 Alexander Fedulov (Jira)
• 2025/02/20 Re: [PR] [FLINK-37336][python] Introduce TablePipeline descriptor to Python Table API [flink] via GitHub
• 2025/02/20 Re: [PR] [FLINK-37336][python] Introduce TablePipeline descriptor to Python Table API [flink] via GitHub
• 2025/02/20 Re: [PR] [FLINK-37336][python] Introduce TablePipeline descriptor to Python Table API [flink] via GitHub
• 2025/02/20 Re: [PR] [hotfix] Fix post-release japicmp update script for macOS [flink] via GitHub
• 2025/02/20 Re: [PR] [FLINK-37336][python] Introduce TablePipeline descriptor to Python Table API [flink] via GitHub
• 2025/02/20 Re: [PR] [FLINK-37336][python] Introduce TablePipeline descriptor to Python Table API [flink] via GitHub
• 2025/02/20 [PR] [hotfix] Fix post-release japicmp update script for macOS [flink] via GitHub
• 2025/02/20 Re: [PR] [FLINK-37336][python] Introduce TablePipeline descriptor to Python Table API [flink] via GitHub
• 2025/02/20 Re: [PR] [FLINK-37336][python] Introduce TablePipeline descriptor to Python Table API [flink] via GitHub
• 2025/02/20 [jira] [Updated] (FLINK-37359) Docker build fails for Kubernetes operator ASF GitHub Bot (Jira)
• 2025/02/20 [jira] [Commented] (FLINK-37356) Recycle use of kafka producer(which commit error) maybe send data without AddPartitionsToTxnRequest Arvid Heise (Jira)
• 2025/02/20 Re: [PR] [FLINK-37336][python] Introduce TablePipeline descriptor to Python Table API [flink] via GitHub
• 2025/02/20 Re: [PR] [FLINK-37336][python] Introduce TablePipeline descriptor to Python Table API [flink] via GitHub
• 2025/02/20 [PR] [hotfix] Fix post-release japicmp update script for macOS [flink] via GitHub
• 2025/02/20 Re: [PR] [FLINK-37336][python] Introduce TablePipeline descriptor to Python Table API [flink] via GitHub
• 2025/02/20 Re: [PR] [FLINK-37336][python] Introduce TablePipeline descriptor to Python Table API [flink] via GitHub
• 2025/02/20 Re: [PR] [BP-2.0][FLINK-37149][doc] Add documents for adaptive batch execution. [flink] via GitHub
• 2025/02/20 Re: [PR] [FLINK-37336][python] Introduce TablePipeline descriptor to Python Table API [flink] via GitHub
• 2025/02/20 Re: [PR] [FLINK-37336][python] Introduce TablePipeline descriptor to Python Table API [flink] via GitHub
• 2025/02/20 [PR] [FLINK-37359] Use pinned qemu image [flink-kubernetes-operator] via GitHub
• 2025/02/20 Re: [PR] [FLINK-37336][python] Introduce TablePipeline descriptor to Python Table API [flink] via GitHub
• 2025/02/20 Re: [PR] [hotfix] Fix post-release japicmp update script for macOS [flink] via GitHub
• 2025/02/20 Re: [PR] [FLINK-37336][python] Introduce TablePipeline descriptor to Python Table API [flink] via GitHub
• 2025/02/20 Re: [PR] [FLINK-37329][table-planner] Skip Source Stats Collection When table.optimizer.source.report-statistics-enabled is False [flink] via GitHub
• 2025/02/20 Re: [PR] [FLINK-36409] Publish some autoscaler metrics during stabilisation period [flink-kubernetes-operator] via GitHub
• 2025/02/20 Re: [PR] [FLINK-37327] [Formats (JSON, Avro, Parquet, ORC, SequenceFile)] Debezium Avro Format: Add FormatOption to Optionally Skip emitting UPDATE_BEFORE Rows [flink] via GitHub
• 2025/02/20 Re: [PR] [FLINK-36549][formats] Fix using the ignore-parse-errors parameter in Debezium/Canal/Maxwell/Ogg JSON results in unexpected data loss [flink] via GitHub
• 2025/02/20 Re: [PR] [FLINK-30371] Fix the problem of JdbcOutputFormat database connection leak [flink-connector-jdbc] via GitHub
• 2025/02/20 [jira] [Closed] (FLINK-36549) Using the ignore-parse-errors parameter in Debezium/Canal/Maxwell/Ogg JSON results in unexpected data loss. Benchao Li (Jira)
• 2025/02/20 Re: [PR] [FLINK-36549][formats] Fix using the ignore-parse-errors parameter in Debezium/Canal/Maxwell/Ogg JSON results in unexpected data loss [flink] via GitHub
• 2025/02/20 [jira] [Created] (FLINK-37359) Docker build fails for Kubernetes operator Gyula Fora (Jira)
• 2025/02/20 Re: [PR] [FLINK-36409] Publish some autoscaler metrics during stabilisation period [flink-kubernetes-operator] via GitHub
• 2025/02/20 Re: [PR] [FLINK-36409] Publish some autoscaler metrics during stabilisation period [flink-kubernetes-operator] via GitHub
• 2025/02/20 [jira] [Commented] (FLINK-36549) Using the ignore-parse-errors parameter in Debezium/Canal/Maxwell/Ogg JSON results in unexpected data loss. xiaoyu (Jira)
• 2025/02/20 [jira] [Commented] (FLINK-37069) Cross-team verification for "Disaggregated State Management" Zakelly Lan (Jira)
• 2025/02/20 Re: [PR] [FLINK-37348][pipeline-paimon] fix paimon ArrayIndexOutOfBoundsException when add column first [flink-cdc] via GitHub
• 2025/02/20 [jira] [Commented] (FLINK-37356) Recycle use of kafka producer(which commit error) maybe send data without AddPartitionsToTxnRequest Hongshun Wang (Jira)
• 2025/02/20 Re: [PR] [BP-2.0][FLINK-37149][doc] Add documents for adaptive batch execution. [flink] via GitHub
• 2025/02/20 Re: [PR] [FLINK-36659] Bump to 2.0-preview1. [flink-connector-jdbc] via GitHub
• 2025/02/20 Re: [PR] [FLINK-37350][table-planner] Fix memory leak caused by skewed join optimization strategy [flink] via GitHub
• 2025/02/20 [PR] [BP-2.0][FLINK-37149][doc] Add documents for adaptive batch execution. [flink] via GitHub
• 2025/02/20 Re: [PR] [FLINK-37149][doc] Add documents for adaptive batch execution. [flink] via GitHub
• 2025/02/20 Re: [PR] [FLINK-37350][table-planner] Fix memory leak caused by skewed join optimization strategy [flink] via GitHub
• 2025/02/20 [jira] [Commented] (FLINK-37069) Cross-team verification for "Disaggregated State Management" Weijie Guo (Jira)
• 2025/02/20 Re: [PR] [FLINK-37350][table-planner] Fix memory leak caused by skewed join optimization strategy [flink] via GitHub
• 2025/02/20 Re: [PR] [FLINK-37350][table-planner] Fix memory leak caused by skewed join optimization strategy [flink] via GitHub
• 2025/02/20 Re: [PR] [BP-2.0][FLINK-28047][docs] Remove deprecated StreamExecutionEnvironment#readTextFile method in documentation [flink] via GitHub
• 2025/02/20 [jira] [Commented] (FLINK-37356) Recycle use of kafka producer(which commit error) maybe send data without AddPartitionsToTxnRequest Arvid Heise (Jira)
• 2025/02/20 [jira] [Updated] (FLINK-37350) Memory leak caused by skewed join optimization strategy ASF GitHub Bot (Jira)
• 2025/02/20 [PR] [FLINK-37350][table-planner] Fix memory leak caused by skewed join optimization strategy [flink] via GitHub
• 2025/02/19 [jira] [Comment Edited] (FLINK-37334) Fix mysql's add column after event becomes add column last MOBIN (Jira)
• 2025/02/19 [jira] [Closed] (FLINK-37334) Fix mysql's add column after event becomes add column last MOBIN (Jira)
• 2025/02/19 [PR] [FLINK-37358][kafka] Support to pass format options [flink-cdc] via GitHub
• 2025/02/19 [jira] [Updated] (FLINK-37358) Support pass format options to kafka pipeline sink ASF GitHub Bot (Jira)
• 2025/02/19 Re: [PR] [FLINK-36086] [Sqlserver] Fix Sqlserver restart during one transaction [flink-cdc] via GitHub
• 2025/02/19 [jira] [Created] (FLINK-37358) Support pass format options to kafka pipeline sink Xiao Huang (Jira)
• 2025/02/19 Re: [PR] [FLINK-36611][pipeline-connector][kafka] Add schema info to output of Kafka sink [flink-cdc] via GitHub
• 2025/02/19 Re: [PR] [BP-2.0][FLINK-37274] Add examples for DataStream V2 [flink] via GitHub
• 2025/02/19 Re: [PR] [FLINK-37333][runtime] Use ForwardForUnspecifiedPartitioner when adaptive broadcast join takes effect [flink] via GitHub
• 2025/02/19 Re: [PR] [FLINK-36611][pipeline-connector][kafka] Add schema info to output of Kafka sink [flink-cdc] via GitHub
• 2025/02/19 [PR] [FLINK-37333][runtime] Use ForwardForUnspecifiedPartitioner when adaptive broadcast join takes effect [flink] via GitHub
• 2025/02/19 [jira] [Updated] (FLINK-37334) Fix mysql's add column after event becomes add column last MOBIN (Jira)
• 2025/02/19 [jira] [Commented] (FLINK-37048) Cross-team verification for "Remove Deprecated methods/fields/classes in DataStream API" Junrui Lee (Jira)
• 2025/02/19 [jira] [Closed] (FLINK-37048) Cross-team verification for "Remove Deprecated methods/fields/classes in DataStream API" Junrui Lee (Jira)
• 2025/02/19 [jira] [Closed] (FLINK-37160) Cross-team verification for "Adaptive broadcast join for batch jobs" Junrui Lee (Jira)
• 2025/02/19 [jira] [Commented] (FLINK-37160) Cross-team verification for "Adaptive broadcast join for batch jobs" Junrui Lee (Jira)
• 2025/02/19 [jira] [Commented] (FLINK-37160) Cross-team verification for "Adaptive broadcast join for batch jobs" Lei Yang (Jira)
• 2025/02/19 [jira] [Comment Edited] (FLINK-37160) Cross-team verification for "Adaptive broadcast join for batch jobs" Lei Yang (Jira)
• 2025/02/19 Re: [PR] [hotfix][runtime] Remove the redundant JobVertex#hasNoConnectedInputs and use JobVertex#isInputVertex instead. [flink] via GitHub
• 2025/02/19 Re: [PR] [hotfix][runtime] Remove the redundant JobVertex#hasNoConnectedInputs and use JobVertex#isInputVertex instead. [flink] via GitHub
• 2025/02/19 Re: [PR] [FLINK-35724][oss] Bump OSS SDK to 3.17.4 [flink] via GitHub
• 2025/02/19 Re: [PR] [hotfix][runtime] Remove the unused SchedulerBase#transitionToScheduled method [flink] via GitHub
• 2025/02/19 [jira] [Commented] (FLINK-37357) Migrating conversion logic to SqlNodeConverters Hirson Zhang (Jira)
• 2025/02/19 [jira] [Updated] (FLINK-37357) Migrating conversion logic to SqlNodeConverters Hirson Zhang (Jira)
• 2025/02/19 [jira] [Updated] (FLINK-37357) Migrating conversion logic to SqlNodeConverters Hirson Zhang (Jira)
• 2025/02/19 [jira] [Updated] (FLINK-37357) Migrating conversion logic to SqlNodeConverters Hirson Zhang (Jira)
• 2025/02/19 [jira] [Updated] (FLINK-37356) Recycle use of kafka producer(which commit error) maybe send data without AddPartitionsToTxnRequest Hongshun Wang (Jira)
• 2025/02/19 [jira] [Updated] (FLINK-37357) Migrating conversion logic to SqlNodeConverters Hirson Zhang (Jira)
• 2025/02/19 [jira] [Created] (FLINK-37357) Migrating conversion logic to SqlNodeConverters Hirson Zhang (Jira)
• 2025/02/19 [jira] [Closed] (FLINK-37333) Use ForwardForUnspecifiedPartitioner when adaptive broadcast join takes effect Zhu Zhu (Jira)
• 2025/02/19 Re: [PR] [FLINK-37149][doc] Add documents for adaptive batch execution. [flink] via GitHub
• 2025/02/19 [jira] [Updated] (FLINK-35724) javax.xml.bind.JAXBException not found with jdk11 while writing to oss ASF GitHub Bot (Jira)
• 2025/02/19 [PR] [FLINK-35724][oss] Bump OSS SDK to 3.17.4 [flink] via GitHub
• 2025/02/19 [jira] [Commented] (FLINK-35724) javax.xml.bind.JAXBException not found with jdk11 while writing to oss Junrui Lee (Jira)
• 2025/02/19 [jira] [Assigned] (FLINK-35724) javax.xml.bind.JAXBException not found with jdk11 while writing to oss Junrui Lee (Jira)
• 2025/02/19 [jira] [Resolved] (FLINK-37335) ForSt fails to generate the first checkpoint in IncrementalCP and NO_CLAIM mode. Zakelly Lan (Jira)
• 2025/02/19 [jira] [Created] (FLINK-37355) When using the DataStream API of Flink CDC 3.3.0 and setting the tableList to database_name.*, it fails to restore from the checkpoint. longwang0616 (Jira)
• 2025/02/19 Re: [PR] [FLINK-36611][pipeline-connector][kafka] Add schema info to output of Kafka sink [flink-cdc] via GitHub
• 2025/02/19 [jira] [Updated] (FLINK-37334) Fix mysql's add column after event becomes add column last MOBIN (Jira)
• 2025/02/19 [jira] [Updated] (FLINK-37334) Fix mysql's add column after event becomes add column last MOBIN (Jira)
• 2025/02/19 Re: [PR] [FLINK-37333][runtime] Use ForwardForUnspecifiedPartitioner when adaptive broadcast join takes effect. [flink] via GitHub
• 2025/02/19 [jira] [Updated] (FLINK-37334) Fix mysql's add column after event becomes add column last MOBIN (Jira)
• 2025/02/19 [jira] (FLINK-37334) Fix mysql's add column after event becomes add column last MOBIN (Jira)
• 2025/02/19 [jira] [Reopened] (FLINK-37334) Fix mysql's add column after event becomes add column last MOBIN (Jira)
• 2025/02/19 [jira] [Updated] (FLINK-37356) Recycle use of kafka producer(which commit error) maybe send data without AddPartitionsToTxnRequest Hongshun Wang (Jira)
• 2025/02/19 [jira] [Updated] (FLINK-37356) Recycle use of kafka producer(which commit error) maybe send data without AddPartitionsToTxnRequest Hongshun Wang (Jira)
• 2025/02/19 [jira] [Updated] (FLINK-37356) Recycle use of kafka producer(which commit error) may send data without AddPartitionsToTxnRequest Hongshun Wang (Jira)
• 2025/02/19 [jira] [Commented] (FLINK-37356) Recycle use of kafka producer(which commit error) will send data without AddPartitionsToTxnRequest Hongshun Wang (Jira)
• 2025/02/19 [jira] [Updated] (FLINK-37356) Recycle use of kafka producer(which commit error) maybe send data without AddPartitionsToTxnRequest Hongshun Wang (Jira)
• 2025/02/19 [jira] [Created] (FLINK-37356) Recycle use of kafka producer(which commit error) will send data without AddPartitionsToTxnRequest Hongshun Wang (Jira)
• 2025/02/19 Re: [PR] [FLINK-35810][test] increase unittest Xmx to debug FLINK-35810 [flink] via GitHub
• 2025/02/19 [jira] [Updated] (FLINK-37355) When using the DataStream API of Flink CDC 3.3.0 and setting the tableList to database_name.*, it fails to restore from the checkpoint. longwang0616 (Jira)
• 2025/02/19 [jira] [Commented] (FLINK-31880) Bad Test in OrcColumnarRowSplitReaderTest Sai Sharath Dandi (Jira)
• 2025/02/19 Re: [PR] [FLINK-36579][cdc] Fix mysql cdc charset collation sort not equals ja… [flink-cdc] via GitHub
• 2025/02/19 Re: [PR] [FLINK-36579][cdc] Fix mysql cdc charset collation sort not equals ja… [flink-cdc] via GitHub
• 2025/02/19 Re: [PR] [FLINK-36585][connector / common] SplitFetcherManager.close() should not chain runnables to the element queue future in a tight loop. [flink] via GitHub
• 2025/02/19 Re: [PR] [FLINK-36409] Publish some autoscaler metrics during stabilisation period [flink-kubernetes-operator] via GitHub
• 2025/02/19 Re: [PR] [FLINK-36409] Publish some autoscaler metrics during stabilisation period [flink-kubernetes-operator] via GitHub
• 2025/02/19 Re: [PR] [FLINK-36409] Publish some autoscaler metrics during stabilisation period [flink-kubernetes-operator] via GitHub
• 2025/02/19 Re: [PR] [FLINK-36409] Publish some autoscaler metrics during stabilisation period [flink-kubernetes-operator] via GitHub
• 2025/02/19 Re: [PR] [FLINK-36997] Add Log4j JSONTemplateLayout to flink-dist [flink] via GitHub
• 2025/02/19 Re: [PR] [FLINK-36409] Publish some autoscaler metrics during stabilisation period [flink-kubernetes-operator] via GitHub
• 2025/02/19 Re: [PR] [FLINK-36409] Publish some autoscaler metrics during stabilisation period [flink-kubernetes-operator] via GitHub
• 2025/02/19 Re: [PR] [FLINK-36409] Publish some autoscaler metrics during stabilisation period [flink-kubernetes-operator] via GitHub
• 2025/02/19 [jira] [Updated] (FLINK-34554) Using EXACTLY_ONCE with KafkaSink cause broker's OOM due to newly created transactionalId per checkpoint ASF GitHub Bot (Jira)
• 2025/02/19 [PR] [FLINK-34554] Introduce transaction strategies [flink-connector-kafka] via GitHub
• 2025/02/19 [jira] [Commented] (FLINK-37353) [Doc] Add doc for scan.incremental.snapshot.chunk.key-column Mysql Data Sink Leonard Xu (Jira)
• 2025/02/19 [jira] [Assigned] (FLINK-37353) [Doc] Add doc for scan.incremental.snapshot.chunk.key-column Mysql Data Sink Leonard Xu (Jira)
• 2025/02/19 [jira] [Resolved] (FLINK-36585) The SplitFetcherManager.close() can chain the futures in a tight loop. Jiangjie Qin (Jira)
• 2025/02/19 Re: [PR] [FLINK-36585][connector / common] SplitFetcherManager.close() should not chain runnables to the element queue future in a tight loop. [flink] via GitHub
• 2025/02/19 [jira] [Commented] (FLINK-37327) Debezium Avro Format: Add FormatOption to Optionally Skip emitting UPDATE_BEFORE Rows David Radley (Jira)
• 2025/02/19 [jira] [Comment Edited] (FLINK-37327) Debezium Avro Format: Add FormatOption to Optionally Skip emitting UPDATE_BEFORE Rows David Radley (Jira)
• 2025/02/19 Re: [PR] [FLINK-37267][table] Add support for UNNEST WITH ORDINALITY [flink] via GitHub
• 2025/02/19 [jira] [Commented] (FLINK-37327) Debezium Avro Format: Add FormatOption to Optionally Skip emitting UPDATE_BEFORE Rows Kevin Lam (Jira)
• 2025/02/19 [jira] [Comment Edited] (FLINK-37327) Debezium Avro Format: Add FormatOption to Optionally Skip emitting UPDATE_BEFORE Rows David Radley (Jira)
• 2025/02/19 [jira] [Commented] (FLINK-37327) Debezium Avro Format: Add FormatOption to Optionally Skip emitting UPDATE_BEFORE Rows David Radley (Jira)
• 2025/02/19 Re: [PR] [FLINK-37320] [Observer] FINISHED finite streaming jobs incorrectly being set to RECONCILING [flink-kubernetes-operator] via GitHub
• 2025/02/19 [jira] [Resolved] (FLINK-37282) Add backchannel for producer recycling Arvid Heise (Jira)
• 2025/02/19 Re: [PR] [FLINK-37282] Add Backchannel and ProducerPool [flink-connector-kafka] via GitHub
• 2025/02/19 [jira] [Updated] (FLINK-37354) Kubernetes Operator HealthCheck compatibility Anton Solovev (Jira)
• 2025/02/19 Re: [PR] [FLINK-37267][table] Add support for UNNEST WITH ORDINALITY [flink] via GitHub
• 2025/02/19 [jira] [Created] (FLINK-37354) Kubernetes Operator HealthCheck compatibility Anton Solovev (Jira)
• 2025/02/19 Re: [PR] [FLINK-36648] Bump Flink version to Flink 2.0-preview1 [flink-connector-kafka] via GitHub
• 2025/02/19 Re: [PR] Add Flink 1.20.1 release [flink-web] via GitHub
• 2025/02/19 Re: [PR] Add Flink 1.19.2 release [flink-web] via GitHub
• 2025/02/19 Re: [PR] [FLINK-36409] Publish some autoscaler metrics during stabilisation period [flink-kubernetes-operator] via GitHub
• 2025/02/19 [jira] [Created] (FLINK-37352) Write full changelog to Paimon Sink. Yanquan Lv (Jira)
• 2025/02/19 [jira] [Updated] (FLINK-37353) [Doc] Add doc for scan.incremental.snapshot.chunk.key-column Mysql Data Sink Yanquan Lv (Jira)
• 2025/02/19 [jira] [Created] (FLINK-37353) [Doc] Add doc for scan.incremental.snapshot.chunk.key-column Mysql Data Sink Yanquan Lv (Jira)
• 2025/02/19 [jira] [Commented] (FLINK-37335) ForSt fails to generate the first checkpoint in IncrementalCP and NO_CLAIM mode. Zakelly Lan (Jira)
• 2025/02/19 Re: [PR] [BP-2.0][FLINK-37335][state/forst] Handle the first full checkpoint for ForSt IncrementalSnapshotStrategy. [flink] via GitHub
• 2025/02/19 [jira] [Updated] (FLINK-37353) [Doc] Add doc for scan.incremental.snapshot.chunk.key-column Mysql Data Sink Yanquan Lv (Jira)
• 2025/02/19 [jira] [Updated] (FLINK-37353) [Doc] Add doc for scan.incremental.snapshot.chunk.key-column Mysql Data Sink Yanquan Lv (Jira)
• 2025/02/19 Re: [PR] [FLINK-37335][state/forst] Handle the first full checkpoint for ForSt IncrementalSnapshotStrategy. [flink] via GitHub
• 2025/02/19 [jira] [Updated] (FLINK-37160) Cross-team verification for "Adaptive broadcast join for batch jobs" Zhu Zhu (Jira)

• Earlier messages
• Later messages