issues

Messages by Date

2025/01/16 [jira] [Updated] (FLINK-34750) "legacy-flink-cdc-sources" Page of Postgresql for Flink CDC Chinese Documentation. Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-35090) Doris sink fails to create table when database does not exist Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-34904) [Feature] submit Flink CDC pipeline job to yarn application cluster. Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-34752) "legacy-flink-cdc-sources" Page of TIDB for Flink CDC Chinese Documentation. Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-34749) "legacy-flink-cdc-sources" Page of SQLServer for Flink CDC Chinese Documentation. Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-36708) Optimize Table Collection Handling Logic to Improve Efficiency Ruan Hang (Jira)
2025/01/16 [jira] [Commented] (FLINK-36167) testSinkDisorderChangeLog failed on AZP Shuai Xu (Jira)
2025/01/16 [jira] [Comment Edited] (FLINK-36167) testSinkDisorderChangeLog failed on AZP Shuai Xu (Jira)
2025/01/16 [jira] [Updated] (FLINK-35873) Add HashFunctionProvider for Paimon DataSink. Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-34735) "Developer Guide - Understanding Flink CDC API" Page for Flink CDC Chinese Documentation Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-34747) "legacy-flink-cdc-sources" Page of DB2 for Flink CDC Chinese Documentation. Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-34736) "Deployment - Standalone" Page for Flink CDC Chinese Documentation Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-34748) "legacy-flink-cdc-sources" Page of Oracle for Flink CDC Chinese Documentation. Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-36566) Code optimization: always identify DataChangeEvent before SchemaChangeEvent in Operator Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-35544) No description of Flink Operator in the Deployment of Kubernetes document Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-36263) Include only changed columns in old for canal format in Kakfa Sink Ruan Hang (Jira)
2025/01/16 [jira] [Resolved] (FLINK-35544) No description of Flink Operator in the Deployment of Kubernetes document Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-34730) Translate pages of Flink CDC docs to Chinese Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-34730) Translate pages of Flink CDC docs to Chinese Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-35544) No description of Flink Operator in the Deployment of Kubernetes document Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-36023) Flink CDC K8S Native Application Mode add wrong jar url. Ruan Hang (Jira)
2025/01/16 [jira] [Resolved] (FLINK-36023) Flink CDC K8S Native Application Mode add wrong jar url. Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-36023) Flink CDC K8S Native Application Mode add wrong jar url. Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-36219) Add Flink compatibility matrix of CDC releases Ruan Hang (Jira)
2025/01/16 Re: [PR] [FLINK-37120][pipeline-connector/mysql] Add ending split chunk first to avoid TaskManager oom [flink-cdc] via GitHub
2025/01/16 [jira] [Updated] (FLINK-36573) Add table information of binlog offsets when checkpointing Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-34467) Implement Lineage Interface in Jdbc Connector Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-35849) [flink-cdc] Use expose_snapshot to read snapshot splits of postgres cdc connector. Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-36041) Eliminate Calcite dependency during runtime Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-36844) Postgres CDC document add mapping from postgres timestamp_tz to flink timestamp ltz Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-36041) Eliminate Calcite dependency during runtime Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-36546) Handle batch sources in DataSinkTranslator Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-35671) Support Iceberg CDC Pipeline Sink Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-35173) Debezium for Mysql connector Custom Time Serializer Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-35760) [docs] Add scan.newly-added-table.enabled to docs. Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-35693) Change variable specificOffsetFile, specificOffsetPos and startupTimestampMillis to Offset in StartupOptions Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-36036) CDC remove unused dependency jar from calcite-core Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-36036) CDC remove unused dependency jar from calcite-core Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-36163) Kafka cdc pipeline source supports protobuf format. Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-35664) Flink CDC pipeline transform supports mask function Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-35586) Detected conflict when using Paimon as pipeline sink with parallelism > 1 Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-35586) Detected conflict when using Paimon as pipeline sink with parallelism > 1 Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-35567) CDC BinaryWriter cast NullableSerializerWrapper error Ruan Hang (Jira)
2025/01/16 [jira] [Resolved] (FLINK-35344) Move same code from multiple subclasses to JdbcSourceChunkSplitter Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-35344) Move same code from multiple subclasses to JdbcSourceChunkSplitter Ruan Hang (Jira)
2025/01/16 Re: [PR] [FLINK-37133][table] Support Submitting Refresh Tasks of Materialized Table to Yarn/K8s [flink] via GitHub
2025/01/16 [jira] [Updated] (FLINK-35459) Use Incremental Source Framework in Flink CDC TiKV Source Connector Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-35450) Introduce Tikv pipeline DataSource Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-35344) Move same code from multiple subclasses to JdbcSourceChunkSplitter Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-35344) Move same code from multiple subclasses to JdbcSourceChunkSplitter Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-35296) Flink mysql-cdc connector stops reading data Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-34853) [Feature] submit Flink CDC pipeline job to k8s cluster. Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-36459) Add document to guide user to configure debezium properties Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-36581) Allow passing Flink configuration by yaml job file or command line parameters Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-36222) Support the use of LLM models for data processing in the transform module. Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-34595) Fix ClassNotFoundException: com.ververica.cdc.common.utils.StringUtils Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-35757) support read new tables when scanNewlyTableAdded is enabled Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-35071) Remove dependency on flink-shaded from cdc source connector Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-35071) Remove dependency on flink-shaded from cdc source connector Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-34737) "Deployment - Kubernetes" Page for Flink CDC Chinese Documentation Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-35968) Remove flink-cdc-runtime depedency from connectors Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-36285) Modify column type failed when downstream's column with defalut value Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-36514) Unable to override include/exclude schema types in lenient mode Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-35713) Add sink PARALLELISM for flink-cdc Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-35093) Postgres source connector support SPECIFIC_OFFSETS start up mode from an existed replication slot. Ruan Hang (Jira)
2025/01/16 Re: [PR] [FLINK-37133][table] Support Submitting Refresh Tasks of Materialized Table to Yarn/K8s [flink] via GitHub
2025/01/16 [jira] [Updated] (FLINK-36798) Improve data processing speed during the phase from snapshot to incremental phase Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-36682) Add split assign strategy to avoid OOM error in TaskManager Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-36061) Support Apache iceberg for pipeline connector Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-36866) Support more CDC YAML numeric casting paths Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-36611) Add schema info to output of Kafka sink Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-36742) Filter unacked split for no capture tables when task restore from state Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-36852) Avoid StackOverflowError in Paimon Pipeline sink Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-36178) Parse CREATE TABLE LIKE to CreateTableEvent correctly. Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-36813) MySQLCDC supports synchronization of specified fields Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-36564) Running CI in random timezone to expose more time related bugs Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-34944) Use Incremental Source Framework in Flink CDC OceanBase Source Connector Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-36683) Support metadata 'row_kind' virtual column for Mongo CDC Connector Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-36763) Support schema inference and evolution with single-table-mutliple-partition sources Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-36996) The schema and namespace of MySQL pipeline connector metadata are reversed Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-36978) Fix the bug where the command-line option `from-savepoint` is invalid in K8s deployment mode. Ruan Hang (Jira)
2025/01/16 Re: [PR] [FLINK-37133][table] Support Submitting Refresh Tasks of Materialized Table to Yarn/K8s [flink] via GitHub
2025/01/16 [jira] [Updated] (FLINK-35759) [docs] Add 'scan.incremental.snapshot.backfill.skip' to docs. Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-36978) Fix the bug where the command-line option `from-savepoint` is invalid in K8s deployment mode. Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-36978) Fix the bug where the command-line option `from-savepoint` is invalid in K8s deployment mode. Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-36684) Support read changelog as append only mode for MySQL CDC connector Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-36978) Fix the bug where the command-line option `from-savepoint` is invalid in K8s deployment mode. Ruan Hang (Jira)
2025/01/16 Re: [PR] [FLINK-36698][pipeline-connector][elasticsearch] Elasticsearch Pipeline Connector support index sharding [flink-cdc] via GitHub
2025/01/16 [jira] [Updated] (FLINK-37095) test case that used AI model may met quota not enough exception. Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-35759) [docs] Add 'scan.incremental.snapshot.backfill.skip' to docs. Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-35759) [docs] Add 'scan.incremental.snapshot.backfill.skip' to docs. Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-37095) test case that used AI model may met quota not enough exception. Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-36967) Bump dependency of Paimon Pipeline connector to 0.9.0 Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-36452) Avoid EOFException when reading binlog after a large table has just completed snapshot reading Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-37114) Flink CDC Postgres Connector subsribe regular expression will be slow Ruan Hang (Jira)
2025/01/16 [jira] [Updated] (FLINK-36333) FLIP-475: Support Adaptive Skewed Join Optimization Junrui Lee (Jira)
2025/01/16 Re: [PR] [FLINK-35152][pipeline-connector/doris] Support create doris auto partition table [flink-cdc] via GitHub
2025/01/16 [jira] [Updated] (FLINK-35152) Flink CDC Doris Sink Auto create table event should support setting auto partition fields for each table ASF GitHub Bot (Jira)
2025/01/16 [PR] Update cdc version to 3.4-SNAPSHOT and add release-3.3 docs [flink-cdc] via GitHub
2025/01/16 [PR] [FLINK-35152][pipeline-connector/doris] Support create doris auto partition table [flink-cdc] via GitHub
2025/01/16 [jira] [Closed] (FLINK-36927) Introduce slicing & one stage Window Aggregate with Async State API lincoln lee (Jira)
2025/01/16 Re: [PR] [FLINK-37028] Datastream Window operator with async state processing [flink] via GitHub
2025/01/16 Re: [PR] [FLINK-37028] Datastream Window operator with async state processing [flink] via GitHub
2025/01/16 Re: [PR] [FLINK-37028] Datastream Window operator with async state processing [flink] via GitHub
2025/01/16 Re: [PR] [FLINK-37028] Datastream Window operator with async state processing [flink] via GitHub
2025/01/16 Re: [PR] [FLINK-37028] Datastream Window operator with async state processing [flink] via GitHub
2025/01/16 [jira] [Commented] (FLINK-36167) testSinkDisorderChangeLog failed on AZP Weijie Guo (Jira)
2025/01/16 [jira] [Updated] (FLINK-37157) Enable daily benchmark for Java 21 Zakelly Lan (Jira)
2025/01/16 [jira] [Created] (FLINK-37157) Enable daily benchmark for Java 21 Zakelly Lan (Jira)
2025/01/16 Re: [PR] Fixed the problem of using the same executor to process schema change requests and flush event requests, resulting in blocking timeout. [flink-cdc] via GitHub
2025/01/16 Re: [PR] [FLINK-36927][table] Introduce slicing & one stage Window Aggregate with Async State API [flink] via GitHub
2025/01/16 [jira] [Updated] (FLINK-36713) NoSuchMethodError: PostgresConnection with PostgresIncrementalSource ar runtime Leonard Xu (Jira)
2025/01/16 [jira] [Updated] (FLINK-34865) [enhancement] [StarRocks] When synchronizing tables using Flink CDC 3.x, is it possible to include the comments of the source table's fields when creating the target table? Leonard Xu (Jira)
2025/01/16 [jira] [Updated] (FLINK-34865) [enhancement] [StarRocks] When synchronizing tables using Flink CDC 3.x, is it possible to include the comments of the source table's fields when creating the target table? Leonard Xu (Jira)
2025/01/16 Re: [PR] Fixed the problem of using the same executor to process schema change requests and flush event requests, resulting in blocking timeout. [flink-cdc] via GitHub
2025/01/16 Re: [PR] Fixed the problem of using the same executor to process schema change requests and flush event requests, resulting in blocking timeout. [flink-cdc] via GitHub
2025/01/16 [jira] [Comment Edited] (FLINK-34865) [enhancement] [StarRocks] When synchronizing tables using Flink CDC 3.x, is it possible to include the comments of the source table's fields when creating the target table? Leonard Xu (Jira)
2025/01/16 Re: [PR] Fixed the problem of using the same executor to process schema change requests and flush event requests, resulting in blocking timeout. [flink-cdc] via GitHub
2025/01/16 Re: [PR] [FLINK-34865][pipeline-connector/mysql] Support sync table comment in binlog phase [flink-cdc] via GitHub
2025/01/16 Re: [PR] Fixed the problem of using the same executor to process schema change requests and flush event requests, resulting in blocking timeout. [flink-cdc] via GitHub
2025/01/16 Re: [PR] Fixed the problem of using the same executor to process schema change requests and flush event requests, resulting in blocking timeout. [flink-cdc] via GitHub
2025/01/16 Re: [PR] [FLINK-37133][table] Support Submitting Refresh Tasks of Materialized Table to Yarn/K8s [flink] via GitHub
2025/01/16 Re: [PR] [FLINK-37133][table] Support Submitting Refresh Tasks of Materialized Table to Yarn/K8s [flink] via GitHub
2025/01/16 Re: [PR] [FLINK-37028] Datastream Window operator with async state processing [flink] via GitHub
2025/01/16 Re: [PR] [FLINK-36282][pipeline-connector][cdc-connector][mysql]fix incorrect data type of TINYINT(1) in mysql pipeline connector [flink-cdc] via GitHub
2025/01/16 [jira] [Created] (FLINK-37156) A Flink pipeline supports collecting data once and writing it to multiple sinks. cheng qian (Jira)
2025/01/16 Re: [PR] [FLINK-37140][runtime] Create async timer service when restore async operator [flink] via GitHub
2025/01/16 [jira] [Commented] (FLINK-36293) RocksDBWriteBatchWrapperTest.testAsyncCancellation Zakelly Lan (Jira)
2025/01/16 [jira] [Resolved] (FLINK-36293) RocksDBWriteBatchWrapperTest.testAsyncCancellation Zakelly Lan (Jira)
2025/01/16 Re: [PR] [FLINK-36293][state] make sure register is closed before verification in testAsyncCancellation [flink] via GitHub
2025/01/16 Re: [PR] [FLINK-24398][connectors/kafka] KafkaSourceFetcherManager should re-use an existing SplitFetcher to commit offset if possible [flink] via GitHub
2025/01/16 Re: [PR] [hotfix] Improve error message when config serialization fails [flink] via GitHub
2025/01/16 Re: [PR] [FLINK-34865][pipeline-connector/mysql] Support sync table comment in binlog phase [flink-cdc] via GitHub
2025/01/16 Re: [PR] [FLINK-35405][runtime] Add metrics for AsyncExecutionController [flink] via GitHub
2025/01/16 Re: [PR] [FLINK-26372][runtime][state] Allow to configure Changelog Storage per program [flink] via GitHub
2025/01/16 [jira] [Updated] (FLINK-36159) FLIP-470: Support Adaptive Broadcast Join Junrui Lee (Jira)
2025/01/16 Re: [PR] [FLINK-34865][pipeline-connector/mysql] Support sync table comment in binlog phase [flink-cdc] via GitHub
2025/01/16 [jira] [Commented] (FLINK-37154) Support reading binary data from Kafka in Python DataStream API Dian Fu (Jira)
2025/01/16 [jira] [Assigned] (FLINK-37126) Add Validator for Autoscler Rui Fan (Jira)
2025/01/16 Re: [PR] [FLINK-36293][state] make sure register is closed before verification in testAsyncCancellation [flink] via GitHub
2025/01/16 [jira] [Commented] (FLINK-37126) Add Validator for Autoscler yuanfenghu (Jira)
2025/01/16 [jira] [Resolved] (FLINK-37112) FLIP-499: Support Event Time by Generalized Watermark in DataStream V2 Weijie Guo (Jira)
2025/01/16 Re: [PR] [FLINK-37112] Support Event Time Extension in DataStream V2 [flink] via GitHub
2025/01/16 Re: [PR] [FLINK-36293][state] make sure register is closed before verification in testAsyncCancellation [flink] via GitHub
2025/01/16 Re: [PR] [hotfix][docs] The tab name scala is changed to the uniformly used Scala in the table api document. [flink] via GitHub
2025/01/16 [jira] [Closed] (FLINK-32647) Support config catalog store in python table environment Xingbo Huang (Jira)
2025/01/16 [jira] [Updated] (FLINK-37154) Support reading binary data from Kafka in Python DataStream API Dian Fu (Jira)
2025/01/16 [jira] [Commented] (FLINK-35810) AsyncWaitOperatorTest.testProcessingTimeRepeatedCompleteUnorderedWithRetry fails xuyang (Jira)
2025/01/16 [jira] [Assigned] (FLINK-37154) Support reading binary data from Kafka Dian Fu (Jira)
2025/01/16 Re: [PR] [FLINK-36837][table] Introduce RowTimeDeduplicateFunction with Async State API [flink] via GitHub
2025/01/16 Re: [PR] [FLINK-32647][pyflink] Support create catalog in pyflink table environment [flink] via GitHub
2025/01/16 Re: [PR] [hotfix] Add homepage link to .asf.yaml [flink] via GitHub
2025/01/16 Re: [PR] [FLINK-33218] Replace glob with version parameter [flink] via GitHub
2025/01/16 [jira] [Comment Edited] (FLINK-37154) Support reading binary data from Kafka Chris Teoh (Jira)
2025/01/16 Re: [PR] [FLINK-34865][pipeline-connector/mysql] Support sync table comment in binlog phase [flink-cdc] via GitHub
2025/01/16 [jira] [Commented] (FLINK-37154) Support reading binary data from Kafka Chris Teoh (Jira)
2025/01/16 [jira] [Updated] (FLINK-33510) Update plugin for SBOM generation to 2.7.10 ASF GitHub Bot (Jira)
2025/01/16 Re: [PR] [hotfix][docs] fix flink-table-api-java-bridge artifactId error… [flink] via GitHub
2025/01/16 Re: [PR] [FLINK-33408] Bump the snakeyaml from 1.33 to 2.0 to fix the container vulnerability. [flink] via GitHub
2025/01/16 Re: [PR] [FLINK-33449][table]Support array_contains_seq function [flink] via GitHub
2025/01/16 Re: [PR] [FLINK-33430] Fix `testSerializerTree` test failures [flink] via GitHub
2025/01/16 Re: [PR] Srichter local rescaling [flink] via GitHub
2025/01/16 Re: [PR] [FLINK-33510] Update plugin for SBOM generation to 2.7.10 [flink] via GitHub
2025/01/16 Re: [PR] [FLINK-30284][flink-metrics] Modify configuration of DataDog http reporter url. [flink] via GitHub
2025/01/16 Re: [PR] Feature/expand sql cep [flink] via GitHub
2025/01/16 Re: [PR] Bump @babel/traverse from 7.19.4 to 7.23.2 in /flink-runtime-web/web-dashboard [flink] via GitHub
2025/01/16 Re: [PR] Draft [FLINK-33335] (CI) [flink] via GitHub
2025/01/16 Re: [PR] [FLINK-33362][doc] Document Externalized Declarative Resource Management With Chinese [flink] via GitHub
2025/01/16 Re: [PR] [FLINK-33328] Allow TwoPhaseCommittingSink WithPreCommitTopology to alter the type of the Committable [flink] via GitHub
2025/01/16 Re: [PR] [FLINK-32986][test] Fix createTemporaryFunction type inference error [flink] via GitHub
2025/01/16 Re: [PR] [FLINK-31065] New split assigner to reduce task failover cost in batch mode. [flink] via GitHub
2025/01/16 Re: [PR] [FLINK-33267] Support PreparedStatement in JDBC Driver [flink] via GitHub
2025/01/16 Re: [PR] [flink-xxxxx][flink-connectors] Skip missing planned files [flink] via GitHub
2025/01/16 Re: [PR] [FLINK-33345][sql-parse] Sql parse only single statement supported [flink] via GitHub
2025/01/16 Re: [PR] [FLINK-32806]EmbeddedJobResultStore set ttly for non dirty job [flink] via GitHub
2025/01/16 Re: [PR] [FLINK-33398][runtime] Support switching from batch to stream mode for one input stream operator [flink] via GitHub
2025/01/16 Re: [PR] [FLINK-33249][table-planner] comment should be parsed by StringLitera… [flink] via GitHub
2025/01/16 Re: [PR] [FLINK-34865][pipeline-connector/mysql] Support sync table comment in binlog phase [flink-cdc] via GitHub
2025/01/16 Re: [PR] [FLINK-19059]: Support non-time retract mode for OverAggregate operator [flink] via GitHub
2025/01/16 Re: [PR] [FLINK-19059]: Support non-time retract mode for OverAggregate operator [flink] via GitHub
2025/01/16 Re: [PR] [FLINK-36695][Formats] Bump Parquet dependency to 1.14.4 [flink] via GitHub
2025/01/16 [jira] [Created] (FLINK-37155) FLIP-505: Flink History Server Scability Improvements, Remote Data Store Fetch and Per Job Fetch Allison Chang (Jira)
2025/01/16 Re: [PR] [FLINK-37098] Fix selecting time attribute from a view [flink] via GitHub
2025/01/16 Re: [PR] [FLINK-32873][table] - Add config to allow disabling QUERY hints [flink] via GitHub
2025/01/16 Re: [PR] Bump org.apache.avro:avro from 1.8.2 to 1.11.3 in /flink-connectors/flink-sql-connector-hive-3.1.3 [flink] via GitHub
2025/01/16 Re: [PR] FLINK-30893 Replace not specifying a driver in Minikube by something … [flink] via GitHub
2025/01/16 Re: [PR] Bump org.apache.avro:avro from 1.8.2 to 1.11.3 in /flink-connectors/flink-connector-hive [flink] via GitHub
2025/01/16 Re: [PR] [FLINK-33159] [build] use variables in pom file for Java and Maven versions [flink] via GitHub
2025/01/16 Re: [PR] [FLINK-33156][Test]Remove flakiness from tests in OperatorStateBackendTest.java [flink] via GitHub
2025/01/16 Re: [PR] [BP-1.18][FLINK-32976][runtime] Fix NullPointException when starting flink cluster in standalone mode [flink] via GitHub
2025/01/16 Re: [PR] [FLINK-33130]reuse source and sink operator io metrics for task [flink] via GitHub
2025/01/16 Re: [PR] [FLINK-20886] Support printing the thread dump when checkpoint expired [flink] via GitHub
2025/01/16 Re: [PR] [FLINK-33095] Job jar issue should be reported as BAD_REQUEST instead of INTERNAL_SERVER_ERROR. [flink] via GitHub
2025/01/16 Re: [PR] [FLINK-33085][table-planner] Improve the error message when the invalidated lookupTableSource without primary key is used as temporal join table [flink] via GitHub
2025/01/16 Re: [PR] [FLINK-32738][formats] PROTOBUF format supports projection push down [flink] via GitHub
2025/01/16 Re: [PR] [FLINK-32488][REST] Introduce configuration for web cache TTL [flink] via GitHub
2025/01/16 Re: [PR] Bump com.github.tomakehurst:wiremock-jre8 from 2.32.0 to 2.35.1 in /flink-metrics/flink-metrics-influxdb [flink] via GitHub
2025/01/16 Re: [PR] Bump org.apache.kafka:kafka-clients from 2.2.2 to 2.6.3 in /flink-end-to-end-tests/flink-sql-client-test [flink] via GitHub
2025/01/16 Re: [PR] [FLINK-33034][Backport][runtime] Correct ValueState creating for StateBackendTestBase#testGetKeysAndNamespaces [flink] via GitHub
2025/01/16 Re: [PR] [docs-zh] fix one word translation issue of flink-architecture.md [flink] via GitHub