issues
Thread
Date
Earlier messages
Later messages
Messages by Date
2024/04/25
Re: [PR] Add a AbstractJdbcSourceChunkSplitter to handle common logic [flink-cdc]
via GitHub
2024/04/25
[PR] [FLINK-35236] [chinese-translation] Modify Translation error on the e… [flink]
via GitHub
2024/04/25
Re: [PR] [Bug][issues-2187] if splitTable method execute fast than getNext, job will be blocked [flink-cdc]
via GitHub
2024/04/25
Re: [PR] using tikv limited scan to avoid oom [flink-cdc]
via GitHub
2024/04/25
Re: [PR] Update mysql binlog connector & changes for transaction payload events [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [core] make ObjectUtils can not be instantiated [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [mysql] Support mysql primary keys using encoding types different fro… [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [tidb]fix the tidb checkpoints to exactly once. [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [FLINK-35236] [chinese-translation] Modify Translation error on the execution_mode/order-of-processing [flink]
via GitHub
2024/04/25
Re: [PR] [FLINK-35236] [chinese-translation] Modify Translation error on the execution_mode/order-of-processing [flink]
via GitHub
2024/04/25
Re: [PR] Use Schema#newBuilder instead of TableSchema#fromResolvedSchema [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [oracle-cdc]Optimized slow oracle real-time synchronization [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [tidb] Add metrics for tidb connector [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [FLINK-35236] [chinese-translation] Modify Translation error on the execution_mode/order-of-processing [flink]
via GitHub
2024/04/25
Re: [PR] [mysql-cdc] Fix MySqlSplitSerializer ConcurrentModificationException [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [oracle-cdc] fix oracle scn huge increment, can not catch up new record in time #1940 [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [oracle-cdc] Fix read one record in the incremental snapshot [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [mysql-cdc] Fix the hung up of snapshot phase when reuse binaryLogClient [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [mysql-cdc] Add upsert changelog mode to avoid UPDATE_BEFORE records … [flink-cdc]
via GitHub
2024/04/25
[jira] [Commented] (FLINK-35178) Checkpoint CLAIM mode does not fully control snapshot ownership
Yanfei Lei (Jira)
2024/04/25
Re: [PR] [postgresql] Fix debezium-postgresql data loss [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [FLINK-35228][Connectors/Kafka] Fix DynamicKafkaSourceEnumerator removed topics state cleanup [flink-connector-kafka]
via GitHub
2024/04/25
Re: [PR] [mysql][Improvement] Use debezium SPI way converter data types output. [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [cdc][base]Support dynamically table addition in flink-cdc-base [flink-cdc]
via GitHub
2024/04/25
[jira] [Updated] (FLINK-35189) Introduce test-filesystem Catalog based on FileSystem Connector to support materialized table
dalongliu (Jira)
2024/04/25
Re: [PR] [build] Add maven wrapper [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [oceanBase] add metrics for oceanbase cdc connector [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [cdc-base] Support `Scan Newly Added Tables` feature [flink-cdc]
via GitHub
2024/04/25
[jira] [Updated] (FLINK-34127) Kafka connector repo runs a duplicate of `IntegrationTests` framework tests
ASF GitHub Bot (Jira)
2024/04/25
Re: [PR] [FLINK-34127] Upgrade to flink-connector-parent 1.1.0 to exclude runn… [flink-connector-kafka]
via GitHub
2024/04/25
Re: [PR] [Fix a Bug] add supported for Oracle CDB mode at OracleIncrementalSource [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [FLINK-35190][table] Support create materialized table syntax [flink]
via GitHub
2024/04/25
Re: [PR] [FLINK-35189][testing/test-filesystem]Introduce test-filesystem Catalog based on FileSystem Connector to support materialized table [flink]
via GitHub
2024/04/25
Re: [PR] [common] Improve implementation of offset backing store [flink-cdc]
via GitHub
2024/04/25
[jira] [Closed] (FLINK-35238) AZP is not working since some ci agent unhealthy
Weijie Guo (Jira)
2024/04/25
[jira] [Assigned] (FLINK-34977) FLIP-433: State Access on DataStream API V2
Weijie Guo (Jira)
2024/04/25
Re: [PR] fix bug 'mysql primary key of binary data type is compared incorrectly' [flink-cdc]
via GitHub
2024/04/25
[jira] [Updated] (FLINK-35049) Implement List/Map Async State API for ForStStateBackend
Hangxiang Yu (Jira)
2024/04/25
Re: [PR] [FLINK-35236] [chinese-translation] Modify Translation error on the execution_mode/order-of-processing [flink]
via GitHub
2024/04/25
Re: [PR] [FLINK-35176][Connector/JDBC] Support property authentication connection for JDBC catalog & dynamic table [flink-connector-jdbc]
via GitHub
2024/04/25
[jira] [Resolved] (FLINK-35162) Support grouping state get and put access
Hangxiang Yu (Jira)
2024/04/25
[jira] [Resolved] (FLINK-35125) Implement ValueState for ForStStateBackend
Hangxiang Yu (Jira)
2024/04/25
Re: [PR] [FLINK-35162][state] Implement WriteBatchOperation and general MultiGetOperation for ForSt [flink]
via GitHub
2024/04/25
Re: [PR] [DOC] When type is number,update doc [flink-cdc]
via GitHub
2024/04/25
[jira] [Commented] (FLINK-35236) Flink 1.19 Translation error on the execution_mode/order-of-processing
hongxu han (Jira)
2024/04/25
[jira] [Resolved] (FLINK-35190) Support create materialized table syntax
dalongliu (Jira)
2024/04/25
[jira] [Commented] (FLINK-35190) Support create materialized table syntax
dalongliu (Jira)
2024/04/25
Re: [PR] [FLINK-35190][table] Support create materialized table syntax [flink]
via GitHub
2024/04/25
[jira] [Resolved] (FLINK-35047) Introduce ForStStateBackend to manage ForSt
Hangxiang Yu (Jira)
2024/04/25
Re: [PR] [FLINK-35047][state] Support ForStStateBackend and ForStKeyedStateBackend [flink]
via GitHub
2024/04/25
Re: [PR] Add a table of cdc json type [flink-cdc]
via GitHub
2024/04/25
Re: [PR] Update mysql-postgres-tutorial-zh.md [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [FLINK-35176][Connector/JDBC] Support property authentication connection for JDBC catalog & dynamic table [flink-connector-jdbc]
via GitHub
2024/04/25
Re: [PR] [FLINK-33463][Connector/JDBC] Support the implementation of dynamic source tables based on the new source [flink-connector-jdbc]
via GitHub
2024/04/25
Re: [PR] [FLINK-34915][table] Complete `DESCRIBE CATALOG` syntax [flink]
via GitHub
2024/04/25
Re: [PR] [FLINK-34915][table] Complete `DESCRIBE CATALOG` syntax [flink]
via GitHub
2024/04/25
Re: [PR] [WIP][FLINK-34977][API] Reorganize classes between core and core-api modules [flink]
via GitHub
2024/04/25
[jira] [Updated] (FLINK-34977) FLIP-433: State Access on DataStream API V2
ASF GitHub Bot (Jira)
2024/04/25
[PR] [WIP][FLINK-34977][API] Reorganize classes between core and core-api modules [flink]
via GitHub
2024/04/25
Re: [PR] [FLINK-34902][table] Fix IndexOutOfBoundsException for VALUES [flink]
via GitHub
2024/04/25
[PR] [FLINK-34902][table] Fix IndexOutOfBoundsException for VALUES [flink]
via GitHub
2024/04/25
[jira] [Commented] (FLINK-35232) Support for retry settings on GCS connector
Galen Warren (Jira)
2024/04/25
[jira] [Commented] (FLINK-35232) Support for retry settings on GCS connector
Vikas M (Jira)
2024/04/25
[jira] [Commented] (FLINK-35240) Disable FLUSH_AFTER_WRITE_VALUE to avoid flush per record
Alexander Fedulov (Jira)
2024/04/25
Re: [PR] [FLINK-35189][testing/test-filesystem]Introduce test-filesystem Catalog based on FileSystem Connector to support materialized table [flink]
via GitHub
2024/04/25
[jira] [Updated] (FLINK-35241) Support SQL FLOOR and CEIL functions with SECOND and MINUTE for TIMESTAMP_TLZ
Alexey Leonov-Vendrovskiy (Jira)
2024/04/25
[jira] [Created] (FLINK-35241) Support SQL FLOOR and CEIL functions with SECOND and MINUTE for TIMESTAMP_TLZ
Alexey Leonov-Vendrovskiy (Jira)
2024/04/25
[jira] [Updated] (FLINK-35240) Disable FLUSH_AFTER_WRITE_VALUE to avoid flush per record
Zhongqiang Gong (Jira)
2024/04/25
[jira] [Updated] (FLINK-35240) Disable FLUSH_AFTER_WRITE_VALUE to avoid flush per record
Zhongqiang Gong (Jira)
2024/04/25
[jira] [Updated] (FLINK-35240) Disable FLUSH_AFTER_WRITE_VALUE to avoid flush per record
Zhongqiang Gong (Jira)
2024/04/25
[jira] [Commented] (FLINK-35240) Disable FLUSH_AFTER_WRITE_VALUE to avoid flush per record
Zhongqiang Gong (Jira)
2024/04/25
[jira] [Created] (FLINK-35240) Disable FLUSH_AFTER_WRITE_VALUE to avoid flush per record
Zhongqiang Gong (Jira)
2024/04/25
Re: [PR] [FLINK-35239] [docs] Unset outdated warning [flink]
via GitHub
2024/04/25
Re: [PR] [FLINK-35130][runtime] Simplify AvailabilityNotifierImpl to support speculative scheduler and improve performance [flink]
via GitHub
2024/04/25
[jira] [Updated] (FLINK-31223) sql-client.sh fails to start with ssl enabled
Weijie Guo (Jira)
2024/04/25
[jira] [Closed] (FLINK-31223) sql-client.sh fails to start with ssl enabled
Weijie Guo (Jira)
2024/04/25
[jira] [Commented] (FLINK-31223) sql-client.sh fails to start with ssl enabled
Weijie Guo (Jira)
2024/04/25
[jira] [Commented] (FLINK-35232) Support for retry settings on GCS connector
Galen Warren (Jira)
2024/04/25
Re: [PR] [FLINK-35190][table] Support create materialized table syntax [flink]
via GitHub
2024/04/25
Re: [PR] [FLINK-31223] sql-client.sh fails to start with ssl enabled [flink]
via GitHub
2024/04/25
Re: [PR] [FLINK-31223] sql-client.sh fails to start with ssl enabled [flink]
via GitHub
2024/04/25
Re: [PR] [FLINK-35190][table] Support create materialized table syntax [flink]
via GitHub
2024/04/25
Re: [PR] [hotfix][docs] Fix the invalid link in 1.18 release note [flink]
via GitHub
2024/04/25
Re: [PR] [FLINK-32706][table] Add built-in SPLIT_STRING function [flink]
via GitHub
2024/04/25
Re: [PR] [FLINK-32843][JUnit5 Migration] Migrate the jobmaster package of flink-runtime module to JUnit5 [flink]
via GitHub
2024/04/25
Re: [PR] [FLINK-32843][JUnit5 Migration] Migrate the jobmaster package of flink-runtime module to JUnit5 [flink]
via GitHub
2024/04/25
[PR] [FLINK-32843][JUnit5 Migration] Migrate the jobmaster package of flink-runtime module to JUnit5 [flink]
via GitHub
2024/04/25
[jira] [Updated] (FLINK-32843) [JUnit5 Migration] The jobmaster package of flink-runtime module
ASF GitHub Bot (Jira)
2024/04/25
Re: [PR] [FLINK-35217] Add missing fsync to #closeForCommit in some subclasses of RecoverableFsDataOutputStream. [flink]
via GitHub
2024/04/25
Re: [PR] [FLINK-32877][Filesystem]add HTTP options to gcs-cloud-storage client [flink]
via GitHub
2024/04/25
[jira] [Updated] (FLINK-35217) Missing fsync in FileSystemCheckpointStorage
ASF GitHub Bot (Jira)
2024/04/25
[PR] [FLINK-35217] Add missing fsync to #closeForCommit in some subclasses of RecoverableFsDataOutputStream. [flink]
via GitHub
2024/04/25
[jira] [Assigned] (FLINK-35217) Missing fsync in FileSystemCheckpointStorage
Stefan Richter (Jira)
2024/04/25
Re: [PR] [FLINK-35022][Connector/DynamoDB] Add TypeInformed DDB Element Converter [flink-connector-aws]
via GitHub
2024/04/25
Re: [PR] [FLINK-35239] [docs] Unset outdated warning [flink]
via GitHub
2024/04/25
[jira] [Updated] (FLINK-35239) 1.19 docs show outdated warning
ASF GitHub Bot (Jira)
2024/04/25
Re: [PR] [FLINK-35022][Connector/DynamoDB] Add TypeInformed DDB Element Converter [flink-connector-aws]
via GitHub
2024/04/25
[PR] [FLINK-35239] [docs] Unset outdated warning [flink]
via GitHub
2024/04/25
[jira] [Created] (FLINK-35239) 1.19 docs show outdated warning
Ufuk Celebi (Jira)
2024/04/25
Re: [PR] [FLINK-32080][FLIP-306][checkpoint] Restoration of FileMergingSnapshotManager [flink]
via GitHub
2024/04/25
Re: [PR] [FLINK-32080][FLIP-306][checkpoint] Restoration of FileMergingSnapshotManager [flink]
via GitHub
2024/04/25
[jira] [Commented] (FLINK-35217) Missing fsync in FileSystemCheckpointStorage
Stefan Richter (Jira)
2024/04/25
Re: [PR] [FLINK-35190][table] Support create materialized table syntax [flink]
via GitHub
2024/04/25
Re: [PR] [FLINK-34379][table] Fix OutOfMemoryError with large queries [flink]
via GitHub
2024/04/25
Re: [PR] [FLINK-34379][table] Fix OutOfMemoryError with large queries [flink]
via GitHub
2024/04/25
Re: [PR] [FLINK-31223] sql-client.sh fails to start with ssl enabled [flink]
via GitHub
2024/04/25
Re: [PR] [FLINK-35196] [Connector / Pulsar] Fix bouncycastle class not found [flink-connector-pulsar]
via GitHub
2024/04/25
Re: [PR] [FLINK-33463][Connector/JDBC] Support the implementation of dynamic source tables based on the new source [flink-connector-jdbc]
via GitHub
2024/04/25
Re: [PR] [FLINK-35176][Connector/JDBC] Support property authentication connection for JDBC catalog & dynamic table [flink-connector-jdbc]
via GitHub
2024/04/25
Re: [PR] [FLINK-35196] [Connector / Pulsar] Fix bouncycastle class not found [flink-connector-pulsar]
via GitHub
2024/04/25
Re: [PR] [FLINK-35167][cdc-connector] Introduce MaxCompute pipeline DataSink [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [FLINK-31223] sql-client.sh fails to start with ssl enabled [flink]
via GitHub
2024/04/25
[jira] [Commented] (FLINK-34902) INSERT INTO column mismatch leads to IndexOutOfBoundsException
Jeyhun Karimov (Jira)
2024/04/25
Re: [PR] [tdsql] The first draft of TDSQL-CDC [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [tdsql] The first draft of TDSQL-CDC [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [FLINK-35236] [chinese-translation] Modify Translation error on the execution_mode/order-of-processing [flink]
via GitHub
2024/04/25
Re: [PR] [FLINK-35236] [chinese-translation] Modify Translation error on the execution_mode/order-of-processing [flink]
via GitHub
2024/04/25
[jira] [Updated] (FLINK-35236) Flink 1.19 Translation error on the execution_mode/order-of-processing
ASF GitHub Bot (Jira)
2024/04/25
[PR] [FLINK-35236] [chinese-translation] Modify Translation error on the execution_mode/order-of-processing [flink]
via GitHub
2024/04/25
Re: [PR] [mysql] expose Enumerator metrics via Source Event [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [mysql] expose Enumerator metrics via Source Event [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [mysql] expose Enumerator metrics via Source Event [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [FLINK-31223] sql-client.sh fails to start with ssl enabled [flink]
via GitHub
2024/04/25
Re: [PR] [FLINK-35222][rest] Adding getJobType for AccessExecutionGraph [flink]
via GitHub
2024/04/25
Re: [PR] [docs]Problem with Case Document Format in Quickstart [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [hotfix] make sure run RecordContext#release() in Task thread. [flink]
via GitHub
2024/04/25
Re: [PR] [FLINK-35047][state] Support ForStStateBackend and ForStKeyedStateBackend [flink]
via GitHub
2024/04/25
Re: [PR] [release] Update version to 3.2-SNAPSHOT [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [FLINK-35047][state] Support ForStStateBackend and ForStKeyedStateBackend [flink]
via GitHub
2024/04/25
Re: [PR] [DRAFT] Declare async state processing [flink]
via GitHub
2024/04/25
[jira] [Comment Edited] (FLINK-35236) Flink 1.19 Translation error on the execution_mode/order-of-processing
Weijie Guo (Jira)
2024/04/25
[jira] [Commented] (FLINK-35236) Flink 1.19 Translation error on the execution_mode/order-of-processing
Weijie Guo (Jira)
2024/04/25
[PR] [DRAFT] Declare async state processing [flink]
via GitHub
2024/04/25
[jira] [Updated] (FLINK-35238) AZP is not working since some ci agent unhealthy
Weijie Guo (Jira)
2024/04/25
[jira] [Updated] (FLINK-35238) AZP is not working since some ci agent unhealthy
Weijie Guo (Jira)
2024/04/25
[jira] [Commented] (FLINK-35238) AZP is not working since some ci agent unhealthy
Weijie Guo (Jira)
2024/04/25
[jira] [Commented] (FLINK-35238) AZP is not working since some ci agent unhealthy
Weijie Guo (Jira)
2024/04/25
[jira] [Created] (FLINK-35238) AZP is not working since some ci agent unhealthy
Weijie Guo (Jira)
2024/04/25
[jira] [Updated] (FLINK-28568) Implements a new lookup join operator (sync mode only) with state to eliminate the non determinism
Weijie Guo (Jira)
2024/04/25
[jira] [Updated] (FLINK-28568) Implements a new lookup join operator (sync mode only) with state to eliminate the non determinism
Weijie Guo (Jira)
2024/04/25
Re: [PR] [hotfix] make sure run RecordContext#release() in Task thread. [flink]
via GitHub
2024/04/25
Re: [PR] [FLINK-31223] sql-client.sh fails to start with ssl enabled [flink]
via GitHub
2024/04/25
Re: [PR] [FLINK-35026][runtime][config] Introduce async execution configurations [flink]
via GitHub
2024/04/25
[jira] [Updated] (FLINK-35236) Flink 1.19 Translation error on the execution_mode/order-of-processing
hongxu han (Jira)
2024/04/25
[jira] [Created] (FLINK-35237) Allow Custom HashFunction in PrePartitionOperator for Flink Sink Customization
zhangdingxin (Jira)
2024/04/25
[jira] [Updated] (FLINK-35236) Flink 1.19 Translation error on the Chinese official website
hongxu han (Jira)
2024/04/25
[jira] [Resolved] (FLINK-33506) Make AWS connectors compilable with jdk17
Danny Cranmer (Jira)
2024/04/25
Re: [PR] [oracle]Error when TIMESTAMP_LTZ type is encoded in string type [flink-cdc]
via GitHub
2024/04/25
[jira] [Updated] (FLINK-33506) Make AWS connectors compilable with jdk17
Danny Cranmer (Jira)
2024/04/25
[jira] [Commented] (FLINK-33506) Make AWS connectors compilable with jdk17
Danny Cranmer (Jira)
2024/04/25
Re: [PR] [oracle] The STRUCT type processing exception [flink-cdc]
via GitHub
2024/04/25
[jira] [Updated] (FLINK-35236) Flink 1.19 Translation error on the Chinese official website
hongxu han (Jira)
2024/04/25
[jira] [Created] (FLINK-35236) Flink 1.19 Translation error on the Chinese official website
hongxu han (Jira)
2024/04/25
Re: [PR] [FLINK-35158][runtime] Error handling in StateFuture's callback [flink]
via GitHub
2024/04/25
Re: [PR] [#1770] fix NumberFormatException when mysql server_id is larger than INT_MAX [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [tidb-cdc]When the task runs for a period of time, there are only Resolved Events [flink-cdc]
via GitHub
2024/04/25
[jira] [Commented] (FLINK-35134) Release flink-connector-elasticsearch vX.X.X for Flink 1.19
Weijie Guo (Jira)
2024/04/25
Re: [PR] Switch to a MySQL image with arm64 support [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [FLINK-35134][Connectors/Elasticsearch] Drop support for Flink 1.17 [flink-connector-elasticsearch]
via GitHub
2024/04/25
Re: [PR] [FLINK-35134][Connectors/Elasticsearch] Drop support for Flink 1.17 [flink-connector-elasticsearch]
via GitHub
2024/04/25
Re: [PR] [mysql][oracle] Quote primary key when split snapshot [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [FLINK-35215][core] Fix the bug when Kryo serialize length is 0 [flink]
via GitHub
2024/04/25
Re: [PR] 升级Jackson版本 [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [FLINK-35215][core] Fix the bug when Kryo serialize length is 0 [flink]
via GitHub
2024/04/25
Re: [PR] [hotfix][docs] Fix the invalid link in 1.18 release note [flink]
via GitHub
2024/04/25
Re: [PR] [hotfix][docs] Fix the invalid link in 1.18 release note [flink]
via GitHub
2024/04/25
Re: [PR] [release] Update version to 3.2-SNAPSHOT [flink-cdc]
via GitHub
2024/04/25
[jira] [Updated] (FLINK-35235) Fix missing dependencies in the uber jar
ASF GitHub Bot (Jira)
2024/04/25
Re: [PR] [FLINK-35215][core] Fix the bug when Kryo serialize length is 0 [flink]
via GitHub
2024/04/25
Re: [PR] [release] Update version to 3.2-SNAPSHOT [flink-cdc]
via GitHub
2024/04/25
[jira] [Commented] (FLINK-35215) The performance of serializerKryo and serializerKryoWithoutRegistration are regressed
Rui Fan (Jira)
2024/04/25
[jira] [Comment Edited] (FLINK-35215) The performance of serializerKryo and serializerKryoWithoutRegistration are regressed
Rui Fan (Jira)
2024/04/25
Re: [PR] support table splitting process control when read table snapshot [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [mysql] Support the rate limit when Mysql parallel read data output [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [FLINK-35167][cdc-connector] Introduce MaxCompute pipeline DataSink [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [e2e] optimization for arm64 [flink-cdc]
via GitHub
2024/04/25
[PR] [release] Update version to 3.2-SNAPSHOT [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [mysql] Populate table schemas when scanNewlyAddedTables is enabled in binlog phase [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [docs][pipeline-connector][paimon] fix example bug for `Paimon 'wareh… [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [metric] fix flink cdc metric conflict with flink built in metric [flink-cdc]
via GitHub
2024/04/25
[PR] [docs][pipeline-connector][paimon] fix example bug for `Paimon 'wareh… [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [Debezium] Fix the server timeZone bug of debeziumDeserialization when using dataSream API(#317) [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [FLINK-35026][runtime][config] Introduce async execution configurations [flink]
via GitHub
2024/04/25
[jira] [Assigned] (FLINK-34639) Flink CDC: Support DebeziumDeserializationSchema in OceanBase source connector
Qingsheng Ren (Jira)
2024/04/25
[jira] [Created] (FLINK-35235) Fix missing dependencies in the uber jar
LvYanquan (Jira)
2024/04/25
[jira] [Commented] (FLINK-34639) Flink CDC: Support DebeziumDeserializationSchema in OceanBase source connector
Qingsheng Ren (Jira)
2024/04/25
Re: [PR] [FLINK-35026][runtime][config] Introduce async execution configurations [flink]
via GitHub
2024/04/25
Re: [PR] [FLINK-34639] Support debezium deserializer in OceanBase source connector [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [tdsql] The first draft of TDSQL-CDC [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [mysql] Fix the binlogSplit state incompatibility when upgrading from 2.2.0 [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [mysql] Fix use latest-offset mode during caused add newly table not … [flink-cdc]
via GitHub
2024/04/25
[jira] [Commented] (FLINK-35215) The performance of serializerKryo and serializerKryoWithoutRegistration are regressed
Rui Fan (Jira)
2024/04/25
[jira] [Updated] (FLINK-35215) The performance of serializerKryo and serializerKryoWithoutRegistration are regressed
Rui Fan (Jira)
2024/04/25
Re: [PR] [FLINK-35234][hotfix][cdc-common] Fix NullPointerException of org.apache.flink.cdc.common.configuration.ConfigurationUtils#convertToString [flink-cdc]
via GitHub
2024/04/25
[jira] [Updated] (FLINK-35215) The performance of serializerKryo and serializerKryoWithoutRegistration are regressed
Rui Fan (Jira)
2024/04/24
Re: [PR] [PostgreSQL] Add DeserializationConverterFactory for PostGIS schemas [flink-cdc]
via GitHub
2024/04/24
Re: [PR] [hotfix][docs] Fix the invalid link in 1.18 release note [flink]
via GitHub
2024/04/24
Re: [PR] [FLINK-35228][Connectors/Kafka] Fix DynamicKafkaSourceEnumerator removed topics state cleanup [flink-connector-kafka]
via GitHub
2024/04/24
Re: [PR] [mysql] expose meta_ts field in the metadata through flink sql [flink-cdc]
via GitHub
2024/04/24
Re: [PR] [FLINK-34980] Translate overview document into Chinese [flink-kubernetes-operator]
via GitHub
Earlier messages
Later messages