issues
Thread
Date
Earlier messages
Messages by Date
2024/04/27
Re: [PR] [FLINK-35176][Connector/JDBC] Support property authentication connection for JDBC catalog & dynamic table [flink-connector-jdbc]
via GitHub
2024/04/27
Re: [PR] [FLINK-34980] Translate overview document into Chinese [flink-kubernetes-operator]
via GitHub
2024/04/27
Re: [PR] [FLINK-32852][JUnit5 Migration] Migrate the scheduler package of flink-runtime module to JUnit5 [flink]
via GitHub
2024/04/27
[PR] [FLINK-32852][JUnit5 Migration] Migrate the scheduler package of flink-runtime module to JUnit5 [flink]
via GitHub
2024/04/27
Re: [PR] [FLINK-34980] Translate overview document into Chinese [flink-kubernetes-operator]
via GitHub
2024/04/27
Re: [PR] [FLINK-34980] Translate overview document into Chinese [flink-kubernetes-operator]
via GitHub
2024/04/27
Re: [PR] [FLINK-34980] Translate overview document into Chinese [flink-kubernetes-operator]
via GitHub
2024/04/27
Re: [PR] [FLINK-34980] Translate overview document into Chinese [flink-kubernetes-operator]
via GitHub
2024/04/27
Re: [PR] Reorder dependency flink-table-runtime in pom.xml to avoid dependency conflict. [flink-cdc]
via GitHub
2024/04/27
Re: [PR] [FLINK-35176][Connector/JDBC] Support property authentication connection for JDBC catalog & dynamic table [flink-connector-jdbc]
via GitHub
2024/04/27
[jira] [Commented] (FLINK-34694) Delete num of associations for streaming outer join
Roman Boyko (Jira)
2024/04/27
[jira] [Created] (FLINK-35249) Support DataGeneratorSource in PyFlink
Wei Yuan (Jira)
2024/04/26
Re: [PR] [FLINK-35119][cdc-runtime] Change DataChangeEvent serialization and eserialization [flink-cdc]
via GitHub
2024/04/26
Re: [PR] Fix during the snapshot phase, projection is not being performed according to the user defined schema. [flink-cdc]
via GitHub
2024/04/26
[jira] [Created] (FLINK-35248) Support table/column comment to modify DDL
melin (Jira)
2024/04/26
Re: [PR] support op_type metadata columns [flink-cdc]
via GitHub
2024/04/26
Re: [PR] [FLINK-33211][table] support flink table lineage [flink]
via GitHub
2024/04/26
Re: [PR] [FLINK-33211][table] support flink table lineage [flink]
via GitHub
2024/04/26
Re: [PR] [FLINK-33211][table] support flink table lineage [flink]
via GitHub
2024/04/26
Re: [PR] [FLINK-35228][Connectors/Kafka] Fix: DynamicKafkaSource does not read re-added topic for the same cluster [flink-connector-kafka]
via GitHub
2024/04/26
[jira] [Updated] (FLINK-35247) Upgrade spotless apply to `2.41.1` in flink-connector-parent to work with Java 21
Mason Chen (Jira)
2024/04/26
[jira] [Created] (FLINK-35247) Upgrade spotless apply to `2.41.1` in flink-connector-parent to work with Java 21
Mason Chen (Jira)
2024/04/26
Re: [PR] [FLINK-33211][table] support flink table lineage [flink]
via GitHub
2024/04/26
Re: [PR] [FLINK-33211][table] support flink table lineage [flink]
via GitHub
2024/04/26
[jira] [Comment Edited] (FLINK-35240) Disable FLUSH_AFTER_WRITE_VALUE to avoid flush per record
Zhongqiang Gong (Jira)
2024/04/26
Re: [PR] [FLINK-33210] Cleanup the lineage interface comments [flink]
via GitHub
2024/04/26
[jira] [Commented] (FLINK-35240) Disable FLUSH_AFTER_WRITE_VALUE to avoid flush per record
Zhongqiang Gong (Jira)
2024/04/26
[PR] [FLINK-33210] Cleanup the lineage interface comments [flink]
via GitHub
2024/04/26
Re: [PR] [FLINK-35240][Connectors][format]Disable FLUSH_AFTER_WRITE_VALUE to avoid flush per record for csv format [flink]
via GitHub
2024/04/26
Re: [PR] [FLINK-35182] Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.1 for Flink Pulsar connector [flink-connector-pulsar]
via GitHub
2024/04/26
[jira] [Updated] (FLINK-35240) Disable FLUSH_AFTER_WRITE_VALUE to avoid flush per record
ASF GitHub Bot (Jira)
2024/04/26
[PR] [FLINK-35240][Connectors][format]Disable FLUSH_AFTER_WRITE_VALUE to avoid flush per record for csv format [flink]
via GitHub
2024/04/26
Re: [PR] [FLINK-31223] sql-client.sh fails to start with ssl enabled [flink]
via GitHub
2024/04/26
Re: [PR] [FLINK-27146] [Filesystem] Migrate to Junit5 [flink]
via GitHub
2024/04/26
Re: [PR] [FLINK-31223][sqlgateway] Introduce getFlinkConfigurationOptions to g… [flink]
via GitHub
2024/04/26
[jira] (FLINK-31223) sql-client.sh fails to start with ssl enabled
david radley (Jira)
2024/04/26
Re: [PR] [FLINK-31223][sqlgateway] Introduce getFlinkConfigurationOptions to g… [flink]
via GitHub
2024/04/26
[jira] [Comment Edited] (FLINK-31223) sql-client.sh fails to start with ssl enabled
david radley (Jira)
2024/04/26
[jira] [Commented] (FLINK-31223) sql-client.sh fails to start with ssl enabled
david radley (Jira)
2024/04/26
[jira] [Commented] (FLINK-35240) Disable FLUSH_AFTER_WRITE_VALUE to avoid flush per record
Alexander Fedulov (Jira)
2024/04/26
[jira] [Updated] (FLINK-35240) Disable FLUSH_AFTER_WRITE_VALUE to avoid flush per record
Alexander Fedulov (Jira)
2024/04/26
[jira] [Updated] (FLINK-35240) Disable FLUSH_AFTER_WRITE_VALUE to avoid flush per record
Alexander Fedulov (Jira)
2024/04/26
[jira] [Updated] (FLINK-35240) Disable FLUSH_AFTER_WRITE_VALUE to avoid flush per record
Alexander Fedulov (Jira)
2024/04/26
[jira] [Commented] (FLINK-35232) Support for retry settings on GCS connector
Oleksandr Nitavskyi (Jira)
2024/04/26
[jira] [Updated] (FLINK-35232) Support for retry settings on GCS connector
Oleksandr Nitavskyi (Jira)
2024/04/26
[jira] [Updated] (FLINK-35232) Support for retry settings on GCS connector
Oleksandr Nitavskyi (Jira)
2024/04/26
[jira] [Updated] (FLINK-35232) Support for retry settings on GCS connector
Oleksandr Nitavskyi (Jira)
2024/04/26
Re: [PR] [FLINK-35022][Connector/DynamoDB] Add TypeInformed DDB Element Converter [flink-connector-aws]
via GitHub
2024/04/26
Re: [PR] [FLINK-35228][Connectors/Kafka] Fix: DynamicKafkaSource does not read re-added topic for the same cluster [flink-connector-kafka]
via GitHub
2024/04/26
Re: [PR] [FLINK-35228][Connectors/Kafka] Fix DynamicKafkaSourceEnumerator removed topics state cleanup [flink-connector-kafka]
via GitHub
2024/04/26
Re: [PR] [FLINK-35022][Connector/DynamoDB] Add TypeInformed DDB Element Converter [flink-connector-aws]
via GitHub
2024/04/26
[jira] [Comment Edited] (FLINK-35240) Disable FLUSH_AFTER_WRITE_VALUE to avoid flush per record
Zhongqiang Gong (Jira)
2024/04/26
[jira] [Commented] (FLINK-35240) Disable FLUSH_AFTER_WRITE_VALUE to avoid flush per record
Zhongqiang Gong (Jira)
2024/04/26
[jira] [Commented] (FLINK-35240) Disable FLUSH_AFTER_WRITE_VALUE to avoid flush per record
Zhongqiang Gong (Jira)
2024/04/26
[jira] [Comment Edited] (FLINK-35240) Disable FLUSH_AFTER_WRITE_VALUE to avoid flush per record
Zhongqiang Gong (Jira)
2024/04/26
[jira] [Commented] (FLINK-35246) SqlClientSSLTest.testGatewayMode failed in AZP
Weijie Guo (Jira)
2024/04/26
[jira] [Closed] (FLINK-35246) SqlClientSSLTest.testGatewayMode failed in AZP
Weijie Guo (Jira)
2024/04/26
Re: [PR] [FLINK-35246][test] Fix incorrect address construction in SqlClientSSLTest [flink]
via GitHub
2024/04/26
Re: [PR] [FLINK-35246][test] Fix incorrect address construction in SqlClientSSLTest [flink]
via GitHub
2024/04/26
Re: [PR] [FLINK-34629] Fix non-partition topic subscribe lost. [flink-connector-pulsar]
via GitHub
2024/04/26
Re: [PR] [FLINK-35182] Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.1 for Flink Pulsar connector [flink-connector-pulsar]
via GitHub
2024/04/26
Re: [PR] [FLINK-35196] [Connector / Pulsar] Fix bouncycastle class not found [flink-connector-pulsar]
via GitHub
2024/04/26
Re: [PR] [FLINK-35194][table] Support describe job with job id [flink]
via GitHub
2024/04/26
Re: [PR] [FLINK-31223] sql-client.sh fails to start with ssl enabled [flink]
via GitHub
2024/04/26
[jira] [Updated] (FLINK-35194) Support describe job syntax and execution
ASF GitHub Bot (Jira)
2024/04/26
[PR] [FLINK-35194][table] Support describe job with job id [flink]
via GitHub
2024/04/26
[jira] [Commented] (FLINK-35097) Table API Filesystem connector with 'raw' format repeats last line
David Perkins (Jira)
2024/04/26
Re: [PR] [FLINK-35119][cdc-runtime] Change DataChangeEvent serialization and eserialization [flink-cdc]
via GitHub
2024/04/26
[jira] [Resolved] (FLINK-35026) Introduce async execution configurations
Yanfei Lei (Jira)
2024/04/26
[jira] [Commented] (FLINK-35026) Introduce async execution configurations
Yanfei Lei (Jira)
2024/04/26
Re: [PR] [FLINK-35026][runtime][config] Introduce async execution configurations [flink]
via GitHub
2024/04/26
Re: [PR] [FLINK-27146] [Filesystem] Migrate to Junit5 [flink]
via GitHub
2024/04/26
Re: [PR] Kafka part required for Flink Apicurio Avro support. Prototype for review [flink-connector-kafka]
via GitHub
2024/04/26
Re: [PR] [FLINK-35119][cdc-runtime] Change DataChangeEvent serialization and eserialization [flink-cdc]
via GitHub
2024/04/26
Re: [PR] [FLINK-35119][cdc-runtime] Change DataChangeEvent serialization and eserialization [flink-cdc]
via GitHub
2024/04/26
[jira] [Comment Edited] (FLINK-34694) Delete num of associations for streaming outer join
Roman Boyko (Jira)
2024/04/26
[jira] [Comment Edited] (FLINK-34694) Delete num of associations for streaming outer join
Roman Boyko (Jira)
2024/04/26
[jira] [Comment Edited] (FLINK-34694) Delete num of associations for streaming outer join
Roman Boyko (Jira)
2024/04/26
[jira] [Commented] (FLINK-35192) operator oom
Biao Geng (Jira)
2024/04/26
[jira] [Updated] (FLINK-35192) operator oom
Biao Geng (Jira)
2024/04/26
[jira] [Assigned] (FLINK-35195) Support the execution of create materialized table in continuous refresh mode
dalongliu (Jira)
2024/04/26
[jira] [Commented] (FLINK-35189) Introduce test-filesystem Catalog based on FileSystem Connector to support materialized table
dalongliu (Jira)
2024/04/26
[jira] [Resolved] (FLINK-35189) Introduce test-filesystem Catalog based on FileSystem Connector to support materialized table
dalongliu (Jira)
2024/04/26
Re: [PR] [FLINK-35189][test-utils]Introduce test-filesystem Catalog based on FileSystem Connector to support materialized table [flink]
via GitHub
2024/04/26
[jira] [Assigned] (FLINK-35197) Support the execution of suspend, resume materialized table in continuous refresh mode
dalongliu (Jira)
2024/04/26
[jira] [Commented] (FLINK-35194) Support describe job syntax and execution
dalongliu (Jira)
2024/04/26
[jira] [Assigned] (FLINK-35194) Support describe job syntax and execution
dalongliu (Jira)
2024/04/26
Re: [PR] [FLINK-35119][cdc-runtime] Change DataChangeEvent serialization and eserialization [flink-cdc]
via GitHub
2024/04/26
Re: [PR] [FLINK-35119][cdc-runtime] Change DataChangeEvent serialization and eserialization [flink-cdc]
via GitHub
2024/04/26
[jira] [Commented] (FLINK-35240) Disable FLUSH_AFTER_WRITE_VALUE to avoid flush per record
Alexander Fedulov (Jira)
2024/04/26
[jira] [Resolved] (FLINK-32877) Support for HTTP connect and timeout options while writes in GCS connector
Danny Cranmer (Jira)
2024/04/26
Re: [PR] [FLINK-32877][Filesystem]add HTTP options to gcs-cloud-storage client [flink]
via GitHub
2024/04/26
Re: [PR] [FLINK-32877][Filesystem]add HTTP options to gcs-cloud-storage client [flink]
via GitHub
2024/04/26
Re: [PR] [FLINK-35246][test] Fix incorrect address construction in SqlClientSSLTest [flink]
via GitHub
2024/04/26
[jira] [Assigned] (FLINK-35244) Move package for flink-connector-tidb-cdc test
Jiabao Sun (Jira)
2024/04/26
[jira] [Updated] (FLINK-32877) Support for HTTP connect and timeout options while writes in GCS connector
Danny Cranmer (Jira)
2024/04/26
[jira] [Updated] (FLINK-32877) Support for HTTP connect and timeout options while writes in GCS connector
Danny Cranmer (Jira)
2024/04/26
Re: [PR] [FLINK-32877][Filesystem][Rebased] Add HTTP options to java-storage client [flink]
via GitHub
2024/04/26
Re: [PR] [FLINK-32877][Filesystem][Rebased] Add HTTP options to java-storage client [flink]
via GitHub
2024/04/26
[jira] [Updated] (FLINK-35246) SqlClientSSLTest.testGatewayMode failed in AZP
ASF GitHub Bot (Jira)
2024/04/26
Re: [PR] [FLINK-31223] sql-client.sh fails to start with ssl enabled [flink]
via GitHub
2024/04/26
[jira] [Resolved] (FLINK-35235) Fix missing dependencies in the uber jar
Jiabao Sun (Jira)
2024/04/26
Re: [PR] [FLINK-32877][Filesystem][Rebased] Add HTTP options to java-storage client [flink]
via GitHub
2024/04/26
[jira] [Commented] (FLINK-35194) Support describe job syntax and execution
xuyang (Jira)
2024/04/26
Re: [PR] [FLINK-35235][pipeline-connector][kafka] Fix missing dependencies in the uber jar of Kafka pipeline sink. [flink-cdc]
via GitHub
2024/04/26
[jira] [Assigned] (FLINK-35246) SqlClientSSLTest.testGatewayMode failed in AZP
Weijie Guo (Jira)
2024/04/26
[jira] [Created] (FLINK-35246) SqlClientSSLTest.testGatewayMode failed in AZP
Weijie Guo (Jira)
2024/04/26
[jira] [Commented] (FLINK-35246) SqlClientSSLTest.testGatewayMode failed in AZP
Weijie Guo (Jira)
2024/04/26
Re: [PR] [BP-3.1][FLINK-35235][pipeline-connector][kafka] Fix missing dependencies in the uber jar of Kafka pipeline sink. [flink-cdc]
via GitHub
2024/04/26
[jira] [Comment Edited] (FLINK-35246) SqlClientSSLTest.testGatewayMode failed in AZP
Weijie Guo (Jira)
2024/04/26
Re: [PR] [FLINK-32084][checkpoint] Migrate current file merging of channel state snapshot into the unify file merging framework [flink]
via GitHub
2024/04/26
Re: [PR] [tidb] Add metrics for tidb connector [flink-cdc]
via GitHub
2024/04/26
[jira] [Updated] (FLINK-35246) SqlClientSSLTest.testGatewayMode failed in AZP
Weijie Guo (Jira)
2024/04/26
[jira] [Updated] (FLINK-35246) SqlClientSSLTest.testGatewayMode failed in AZP
Weijie Guo (Jira)
2024/04/26
[jira] [Created] (FLINK-35245) Add metrics for flink-connector-tidb-cdc
Xie Yi (Jira)
2024/04/26
Re: [PR] [FLINK-35217] Add missing fsync to #closeForCommit in some subclasses of RecoverableFsDataOutputStream. [flink]
via GitHub
2024/04/26
[jira] [Updated] (FLINK-35173) Debezium for Mysql connector Custom Time Serializer
Qingsheng Ren (Jira)
2024/04/26
Re: [PR] [FLINK-32843][JUnit5 Migration] Migrate the jobmaster package of flink-runtime module to JUnit5 [flink]
via GitHub
2024/04/26
[jira] [Updated] (FLINK-35245) Add metrics for flink-connector-tidb-cdc
ASF GitHub Bot (Jira)
2024/04/26
[jira] [Commented] (FLINK-35012) ChangelogNormalizeRestoreTest.testRestore failure
Weijie Guo (Jira)
2024/04/26
[jira] [Commented] (FLINK-35041) IncrementalRemoteKeyedStateHandleTest.testSharedStateReRegistration failed
Weijie Guo (Jira)
2024/04/26
Re: [PR] [FLINK-31223] sql-client.sh fails to start with ssl enabled [flink]
via GitHub
2024/04/26
[jira] [Commented] (FLINK-18476) PythonEnvUtilsTest#testStartPythonProcess fails
Weijie Guo (Jira)
2024/04/26
[jira] [Updated] (FLINK-35173) Debezium for Mysql connector Custom Time Serializer
Qingsheng Ren (Jira)
2024/04/26
[jira] [Resolved] (FLINK-35173) Debezium for Mysql connector Custom Time Serializer
Qingsheng Ren (Jira)
2024/04/26
[jira] [Assigned] (FLINK-35173) Debezium for Mysql connector Custom Time Serializer
Qingsheng Ren (Jira)
2024/04/26
[jira] [Commented] (FLINK-35173) Debezium for Mysql connector Custom Time Serializer
Qingsheng Ren (Jira)
2024/04/26
Re: [PR] [BP3.1][FLINK-35173][cdc][mysql] Debezium custom time serializer for MySQL connector (#3240) [flink-cdc]
via GitHub
2024/04/26
Re: [PR] [FLINK-35176][Connector/JDBC] Support property authentication connection for JDBC catalog & dynamic table [flink-connector-jdbc]
via GitHub
2024/04/26
[jira] [Created] (FLINK-35244) Move package for flink-connector-tidb-cdc test
Xie Yi (Jira)
2024/04/26
Re: [PR] [FLINK-35217] Add missing fsync to #closeForCommit in some subclasses of RecoverableFsDataOutputStream. [flink]
via GitHub
2024/04/26
[jira] [Updated] (FLINK-35244) Move package for flink-connector-tidb-cdc test
ASF GitHub Bot (Jira)
2024/04/26
Re: [PR] [BP-3.1][minor][cdc][docs] Add user guide about providing extra jar package in quickstart docs [flink-cdc]
via GitHub
2024/04/26
Re: [PR] [minor][docs] Add user guide about providing extra jar package in quickstart docs [flink-cdc]
via GitHub
2024/04/26
Re: [PR] [cdc-base] Support `Scan Newly Added Tables` feature [flink-cdc]
via GitHub
2024/04/26
Re: [PR] [FLINK-34902][table] Fix IndexOutOfBoundsException for VALUES [flink]
via GitHub
2024/04/26
[jira] [Created] (FLINK-35243) Carry pre-schema payload with SchemaChangeEvents
yux (Jira)
2024/04/26
[jira] [Created] (FLINK-35242) Add fine-grained schema evolution strategy
yux (Jira)
2024/04/26
[jira] [Updated] (FLINK-35072) Doris pipeline sink does not support applying AlterColumnTypeEvent
yux (Jira)
2024/04/26
[jira] [Updated] (FLINK-35090) Doris sink fails to create table when database does not exist
yux (Jira)
2024/04/26
[jira] [Updated] (FLINK-35092) Add integrated test for Doris / Starrocks sink pipeline connector
yux (Jira)
2024/04/26
[jira] [Updated] (FLINK-35120) Add Doris Pipeline connector integration test cases
yux (Jira)
2024/04/26
Re: [PR] [fix] repair a snapshot-split bug: [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [FLINK-32622][table-planner] Optimize mini-batch assignment [flink]
via GitHub
2024/04/25
[jira] [Resolved] (FLINK-35239) 1.19 docs show outdated warning
Ufuk Celebi (Jira)
2024/04/25
Re: [PR] [FLINK-35039][rest] Use PUT method supported by YARN web proxy instead of POST [flink]
via GitHub
2024/04/25
[jira] [Commented] (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
Re: [PR] [FLINK-35173] Debezium for Mysql connector Custom Time Serializer [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-cdc] Add upsert changelog mode to avoid UPDATE_BEFORE records … [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [cdc-common] add field of defaultValue to Column. [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [pipeline-connector][starrocks] Add the binary column type support [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [pipeline-connector] Ability to provide a schema replacement [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
Re: [PR] [cdc-composer][tests] Refactor newline handling for cross-platform compatibility [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [mysql] Error message more cautious [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [pipeline-connector][doris] Extract type mapping logic [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [mysql-cdc] Current binlog offset add serverId, fix incremental-snapshot scan data lose [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [db] When modifying the time zone connection parameters in the datab… [flink-cdc]
via GitHub
2024/04/25
Re: [PR] Refactoring code. [flink-cdc]
via GitHub
2024/04/25
Re: [PR] Reorder dependency flink-table-runtime in pom.xml to avoid dependency conflict. [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [hotfix] [base] Fix the serialization error occurring with table names containing dot [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [FLINK-34689][MySQL][Feature] check binlog_row_value_options [flink-cdc]
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-32706][table] Add built-in SPLIT_STRING function [flink]
via GitHub
2024/04/25
Re: [PR] The uniqueidentifier type in SQL Server cannot be compared using ObjectUtils.compare. [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [postgres] Remove unnecessary schema fresh to improve performance. [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [FLINK-35026][runtime][config] Introduce async execution configurations [flink]
via GitHub
2024/04/25
Re: [PR] [mysql] Add custom configurations for ConnectionPool which starts with `hikari.` [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [WIP][mysql] Add ExternalSystemListener to notify user about the status of connector. [flink-cdc]
via GitHub
2024/04/25
Re: [PR] Fix during the snapshot phase, projection is not being performed according to the user defined schema. [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [docs] format shell code display for mysql-doris-pipeline doc [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [oracle] Support partitioned table [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [postgres] Add lsn as metadata [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [FLINK-35026][runtime][config] Introduce async execution configurations [flink]
via GitHub
2024/04/25
Re: [PR] [base][minor] Code Cleanup, remove redundant code [flink-cdc]
via GitHub
2024/04/25
Re: [PR] hotfix: exclude debezium jackson dependency & add: assorted e2e case [flink-cdc]
via GitHub
2024/04/25
Re: [PR] hotfix: exclude debezium jackson dependency & add: assorted e2e case [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [mysql] Mysql-cdc adapt mariadb. [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [mongodb] Add lookup option to IncrementalSource for mongodb [flink-cdc]
via GitHub
2024/04/25
Re: [PR] Release 2.4 [flink-cdc]
via GitHub
2024/04/25
Re: [PR] Fix an exception:java.lang.NoClassDefFoundError: [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [Postgres] fix lose precision in PostgresParallelSource [flink-cdc]
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] [postgres] PostgresSql snapshot sql [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [postgres] Postgres CDC Connector support automatically identify newly added tables [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [WIP][debezium] Bump debezium version to 2.3.1.Final [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [Improve][code style]Format some idea tips [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [Bug][Oracle] oracle 单表全量阶段根据ROWID 字段 split chunk存在BUG [flink-cdc]
via GitHub
2024/04/25
[jira] [Resolved] (FLINK-34639) Flink CDC: Support DebeziumDeserializationSchema in OceanBase source connector
Qingsheng Ren (Jira)
2024/04/25
[jira] [Comment Edited] (FLINK-34639) Flink CDC: Support DebeziumDeserializationSchema in OceanBase source connector
Qingsheng Ren (Jira)
2024/04/25
Re: [PR] [BP-3.1][FLINK-34639][cdc][oceanbase] Support debezium deserializer in OceanBase source connector [flink-cdc]
via GitHub
2024/04/25
[jira] [Comment Edited] (FLINK-35128) Re-calculate the starting change log offset after the new table added
Qingsheng Ren (Jira)
2024/04/25
[jira] [Resolved] (FLINK-35128) Re-calculate the starting change log offset after the new table added
Qingsheng Ren (Jira)
2024/04/25
Re: [PR] [BP-3.1][FLINK-35128][cdc-connector][cdc-base] Re-calculate the starting changelog offset after the new table added (#3230) [flink-cdc]
via GitHub
2024/04/25
Re: [PR] [jdbc] support read snapshot only [flink-cdc]
via GitHub
2024/04/25
Re: [PR] Support split snapshot asynchronously [flink-cdc]
via GitHub
2024/04/25
[jira] [Commented] (FLINK-35240) Disable FLUSH_AFTER_WRITE_VALUE to avoid flush per record
Rob Young (Jira)
2024/04/25
[jira] (FLINK-35236) Flink 1.19 Translation error on the execution_mode/order-of-processing
hongxu han (Jira)
Earlier messages