issues  

Messages by Date

• 2025/01/17 [jira] [Updated] (FLINK-37165) The starrocks connector is found to be missing some options. sukang (Jira)
• 2025/01/17 Re: [PR] [FLINK-37133][table] Support Submitting Refresh Tasks of Materialized Table to Yarn/K8s [flink] via GitHub
• 2025/01/17 [jira] [Commented] (FLINK-37165) The starrocks connector is found to be missing some options. sukang (Jira)
• 2025/01/17 Re: [PR] [FLINK-37133][table] Support Submitting Refresh Tasks of Materialized Table to Yarn/K8s [flink] via GitHub
• 2025/01/17 [jira] [Created] (FLINK-37165) The starrocks connector is found to be missing some options. sukang (Jira)
• 2025/01/17 [jira] [Commented] (FLINK-36698) Elasticsearch Pipeline Connector support index sharding Yanquan Lv (Jira)
• 2025/01/17 Re: [PR] [FLINK-35405][runtime] Add metrics for AsyncExecutionController [flink] via GitHub
• 2025/01/17 Re: [PR] [FLINK-37159][runtime] Fix the test timeout by yielding Modifier thread [flink] via GitHub
• 2025/01/17 [jira] [Updated] (FLINK-37164) Speed up state v2 synchronous methods execution ASF GitHub Bot (Jira)
• 2025/01/17 Re: [PR] [FLINK-36698][pipeline-connector][elasticsearch] Elasticsearch Pipeline Connector support index sharding [flink-cdc] via GitHub
• 2025/01/17 [PR] [FLINK-37164][Runtime] Speed up state v2 synchronous methods execution [flink] via GitHub
• 2025/01/17 Re: [PR] [FLINK-36698][pipeline-connector][elasticsearch] Elasticsearch Pipeline Connector support index sharding [flink-cdc] via GitHub
• 2025/01/17 Re: [PR] [FLINK-37159][runtime] Fix the test timeout by yielding Modifier thread [flink] via GitHub
• 2025/01/17 Re: [PR] [FLINK-37133][table] Support Submitting Refresh Tasks of Materialized Table to Yarn/K8s [flink] via GitHub
• 2025/01/17 Re: [PR] [FLINK-36698][pipeline-connector][elasticsearch] Elasticsearch Pipeline Connector support index sharding [flink-cdc] via GitHub
• 2025/01/17 Re: [PR] [FLINK-36698][pipeline-connector][elasticsearch] Elasticsearch Pipeline Connector support index sharding [flink-cdc] via GitHub
• 2025/01/17 [jira] [Created] (FLINK-37164) Speed up state v2 synchronous methods execution Zakelly Lan (Jira)
• 2025/01/17 [jira] [Assigned] (FLINK-37163) Add documents for recently merged PRs in FlinkCDC 3.3 Leonard Xu (Jira)
• 2025/01/17 [jira] [Assigned] (FLINK-37162) Add Data Sink Documentation Leonard Xu (Jira)
• 2025/01/17 Re: [PR] [FLINK-35152][pipeline-connector/doris] Support create doris auto partition table [flink-cdc] via GitHub
• 2025/01/17 Re: [PR] [WIP][FLINK-37136] Support Window extension for DataStream V2 [flink] via GitHub
• 2025/01/17 Re: [PR] [WIP][FLINK-37136] Support Window extension for DataStream V2 [flink] via GitHub
• 2025/01/17 Re: [PR] [WIP][FLINK-37136] Support Window extension for DataStream V2 [flink] via GitHub
• 2025/01/17 Re: [PR] [FLINK-31238] [WIP] Use IngestDB to speed up Rocksdb rescaling recovery [flink] via GitHub
• 2025/01/17 Re: [PR] [FLINK-37098] Fix selecting time attribute from a view [flink] via GitHub
• 2025/01/17 Re: [PR] [FLINK-37093][table] Fix catalog that failed validation due to no type still exists in catalogStoreHolder [flink] via GitHub
• 2025/01/17 [jira] [Updated] (FLINK-37163) Add documents for recently merged PRs in FlinkCDC 3.3 ASF GitHub Bot (Jira)
• 2025/01/17 Re: [PR] [FLINK-37133][table] Support Submitting Refresh Tasks of Materialized Table to Yarn/K8s [flink] via GitHub
• 2025/01/17 Re: [PR] [FLINK-37133][table] Support Submitting Refresh Tasks of Materialized Table to Yarn/K8s [flink] via GitHub
• 2025/01/17 Re: [PR] [FLINK-37133][table] Support Submitting Refresh Tasks of Materialized Table to Yarn/K8s [flink] via GitHub
• 2025/01/17 Re: [PR] [FLINK-37084][python] fix TimerRegistration concurrency bug in pyflink [flink] via GitHub
• 2025/01/17 [PR] [FLINK-37084][python] fix TimerRegistration concurrency bug in pyflink [flink] via GitHub
• 2025/01/17 Re: [PR] [FLINK-37084][python] fix TimerRegistration concurrency bug in pyflink [flink] via GitHub
• 2025/01/17 [jira] [Commented] (FLINK-37159) MemoryManagerConcurrentModReleaseTest.testConcurrentModificationWhileReleasing timeout in AZP Luke Chen (Jira)
• 2025/01/17 [jira] [Updated] (FLINK-37159) MemoryManagerConcurrentModReleaseTest.testConcurrentModificationWhileReleasing timeout in AZP ASF GitHub Bot (Jira)
• 2025/01/17 Re: [PR] [FLINK-37159][runtime] Fix the test timeout by yielding Modifier thread [flink] via GitHub
• 2025/01/17 [PR] [FLINK-37159][runtime] Fix the test timeout by yielding Modifier thread [flink] via GitHub
• 2025/01/17 Re: [PR] [FLINK-36488] [TABLE SQL/API] Remove deprecated methods StreamTableEnvironment.toAppendStream from flink-table-api-java-bridge module [flink] via GitHub
• 2025/01/17 Re: [PR] [hotfix] Fix the issue related to mounting the Logback configuration … [flink] via GitHub
• 2025/01/17 [jira] [Created] (FLINK-37163) Add documents for recently merged PRs in FlinkCDC 3.3 Yanquan Lv (Jira)
• 2025/01/16 [jira] [Commented] (FLINK-37001) Remove all direct uses of `TableEnvironmentInternal#registerTableSinkInternal` in table module dalongliu (Jira)
• 2025/01/16 [jira] [Resolved] (FLINK-37001) Remove all direct uses of `TableEnvironmentInternal#registerTableSinkInternal` in table module dalongliu (Jira)
• 2025/01/16 Re: [PR] [FLINK-37001][table] Remove code related to registerTableSinkInternal in tests and remove this method in TableEnvironmentInternal [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 [jira] [Updated] (FLINK-37162) Add Data Sink Documentation Yanquan Lv (Jira)
• 2025/01/16 [jira] [Created] (FLINK-37162) Add Data Sources Documentation Yanquan Lv (Jira)
• 2025/01/16 [jira] [Updated] (FLINK-37162) Add Data Sources Documentation Yanquan Lv (Jira)
• 2025/01/16 Re: [PR] [FLINK-37158][tests] Introduce ForSt to existing ITCases [flink] via GitHub
• 2025/01/16 Re: [PR] [FLINK-37098] Fix selecting time attribute from a view [flink] via GitHub
• 2025/01/16 Re: [PR] [FLINK-37084][python] fix TimerRegistration concurrency bug in pyflink [flink] via GitHub
• 2025/01/16 Re: [PR] [FLINK-37084][python] fix TimerRegistration concurrency bug in pyflink [flink] via GitHub
• 2025/01/16 Re: [PR] [FLINK-36488] [TABLE SQL/API] Remove deprecated methods StreamTableEnvironment.toAppendStream from flink-table-api-java-bridge module [flink] via GitHub
• 2025/01/16 [jira] [Updated] (FLINK-37136) FLIP-501: Support Window Extension in DataStream V2 API ASF GitHub Bot (Jira)
• 2025/01/16 [PR] [WIP][FLINK-37136] Support Window extension for DataStream V2 [flink] via GitHub
• 2025/01/16 [jira] [Updated] (FLINK-37160) Cross-team verification for "Adaptive broadcast join for batch jobs" Junrui Lee (Jira)
• 2025/01/16 [jira] [Updated] (FLINK-37161) Cross-team verification for "Adaptive skewed join optimization for batch jobs" Junrui Lee (Jira)
• 2025/01/16 [jira] [Created] (FLINK-37161) Cross-team verification for "Adaptive skewed join optimization for batch jobs" Junrui Lee (Jira)
• 2025/01/16 [jira] [Created] (FLINK-37160) Cross-team verification for "Adaptive broadcast join for batch jobs" Junrui Lee (Jira)
• 2025/01/16 [jira] [Updated] (FLINK-37113) Introduce documentation for datastream api v2 Weijie Guo (Jira)
• 2025/01/16 Re: [PR] [FLINK-36488] [TABLE SQL/API] Remove deprecated methods StreamTableEnvironment.toAppendStream from flink-table-api-java-bridge module [flink] via GitHub
• 2025/01/16 [jira] [Created] (FLINK-37159) MemoryManagerConcurrentModReleaseTest.testConcurrentModificationWhileReleasing timeout in AZP Weijie Guo (Jira)
• 2025/01/16 Re: [PR] [FLINK-36074][Connectors/mongodb] Support insert overwrite semantics for mongodb table sink [flink-connector-mongodb] via GitHub
• 2025/01/16 [jira] [Updated] (FLINK-37158) Introduce ForSt to existing ITCases ASF GitHub Bot (Jira)
• 2025/01/16 [PR] [FLINK-37158][tests] Introduce ForSt to existing ITCases [flink] via GitHub
• 2025/01/16 [jira] [Commented] (FLINK-35093) Postgres source connector support SPECIFIC_OFFSETS start up mode from an existed replication slot. Vinh Pham (Jira)
• 2025/01/16 [jira] [Created] (FLINK-37158) Introduce ForSt to existing ITCases Yanfei Lei (Jira)
• 2025/01/16 Re: [PR] [FLINK-36488] [TABLE SQL/API] Remove deprecated methods StreamTableEnvironment.toAppendStream from flink-table-api-java-bridge module [flink] via GitHub
• 2025/01/16 [jira] [Updated] (FLINK-36713) NoSuchMethodError: PostgresConnection with PostgresIncrementalSource at runtime Mohsen Rezaei (Jira)
• 2025/01/16 Re: [PR] [FLINK-20886] Support printing the thread dump when checkpoint expired [flink] via GitHub
• 2025/01/16 Re: [PR] [FLINK-37008] [runtime-web] Flink UI should show the type of checkpoint (full vs incremental) [flink] via GitHub
• 2025/01/16 Re: [PR] [FLINK-32753] Print JVM flags on AZP [flink] via GitHub
• 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-35234) Fix NullPointerException of org.apache.flink.cdc.common.configuration.ConfigurationUtils#convertToString Ruan Hang (Jira)
• 2025/01/16 [jira] [Resolved] (FLINK-35234) Fix NullPointerException of org.apache.flink.cdc.common.configuration.ConfigurationUtils#convertToString Ruan Hang (Jira)
• 2025/01/16 [jira] [Updated] (FLINK-35234) Fix NullPointerException of org.apache.flink.cdc.common.configuration.ConfigurationUtils#convertToString Ruan Hang (Jira)
• 2025/01/16 [jira] [Updated] (FLINK-35684) Add missing option for DataSource and DataSink Ruan Hang (Jira)
• 2025/01/16 [jira] [Updated] (FLINK-35684) Add missing option for DataSource and DataSink Ruan Hang (Jira)
• 2025/01/16 [jira] [Updated] (FLINK-35589) Support MemorySize type in FlinkCDC ConfigOptions Ruan Hang (Jira)
• 2025/01/16 [jira] [Updated] (FLINK-35718) Cherrypick DBZ-5333 to fix frequently failover by EOFException. Ruan Hang (Jira)
• 2025/01/16 [jira] [Updated] (FLINK-36827) [Docs] Tidy up Flink CDC Doris/MySQL quickstart page Ruan Hang (Jira)
• 2025/01/16 [jira] [Updated] (FLINK-35888) Add e2e test for paimon DataSink Ruan Hang (Jira)
• 2025/01/16 [jira] [Updated] (FLINK-35834) Update Doris Dependency to 1.6.2 to use group commit. Ruan Hang (Jira)
• 2025/01/16 [jira] [Updated] (FLINK-35444) Paimon Pipeline Connector support changing column names to lowercase for Hive metastore Ruan Hang (Jira)
• 2025/01/16 [jira] [Updated] (FLINK-35349) Use connection in openJdbcConnection of SqlServerDialect/Db2Dialect/OracleDialect Ruan Hang (Jira)
• 2025/01/16 [jira] [Updated] (FLINK-36111) fix: adjust MultiTableCommittableChannelComputer Topology name Ruan Hang (Jira)
• 2025/01/16 [jira] [Updated] (FLINK-36218) Documentations clean up before CDC 3.2.0 release Ruan Hang (Jira)
• 2025/01/16 [jira] [Updated] (FLINK-35919) The rowkind keyword option for MySQL connector metadata should be changed to op_type keyword Ruan Hang (Jira)
• 2025/01/16 [jira] [Updated] (FLINK-36220) Clean up typo and stale links in docs Ruan Hang (Jira)
• 2025/01/16 [jira] [Updated] (FLINK-35627) Avoid conflict when pipeline job that used Paimon as sink restart. Ruan Hang (Jira)
• 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

• Earlier messages
• Later messages