flink-cdc

flink-cdc copied to clipboard

[Debezium] Fix the server timeZone bug of debeziumDeserialization when using dataSream API（#317）

2

Fix the server timeZone bug of debeziumDeserialization when using dataSream API（#317）

youyangkou

flinksql postgresql cdc process geometry type data I get type error

1

**Environment :** - Flink version : 1.14 - Flink CDC version: 2.2 - Database and version: 14 When I process geometry type data I get type error ，i try cdc...

ya-xing

[tdsql] The first draft of TDSQL-CDC

4

TDSQL is an abbreviation for TecentDistributed SQL. **It is derived from MySQL** and designed like mysql cluster. TDSQL CDC base on mysql cdc. It discovers tdsql's set and assigns them's...

guixin

Mongo connectors null pointer exception

1

**Describe the bug(Please use English)** Initial snapshot works fine. Eventually after the snapshot is finished the connector crashes with this exception: java.lang.NullPointerException at org.apache.flink.util.Preconditions.checkNotNull(Preconditions.java:59) at com.ververica.cdc.connectors.mongodb.table.MongoDBConnectorDeserializationSchema.deserialize(MongoDBConnectorDeserializationSchema.java:122) at com.ververica.cdc.debezium.internal.DebeziumChangeFetcher.handleBatch(DebeziumChangeFetcher.java:229) at com.ververica.cdc.debezium.internal.DebeziumChangeFetcher.runFetchLoop(DebeziumChangeFetcher.java:163)...

bobby-richard-sed

Please comment under this issue to propose your wanted feature. ## Feature Development * [ ] #450 * [ ] #456 * [ ] #997 * [ ] #851 *...

leonardBang

[metric] fix flink cdc metric conflict with flink built in metric

7

CurrentEmitEventTimeLag and currentFetchEventTimeLag metrics are both registered in flink cdc and flink framework.Flink MetricRegistryImpl is responsible for metric registering, when the metric with same name is registered twice, only the...

zhmin

**Is your feature request related to a problem? Please describe.** In some scenarios, it is necessary to compare the modified data, so the data before and after need. **Describe the...

fchenxi

[oceanbase] Add metrics for oceanbase cdc connector

1

We can add `currentFetchEventTimeLag`, `currentEmitEventTimeLag` and `sourceIdleTime` metrics for oceanbase cdc connector just like we did in other connector.

leonardBang

[MySQL CDC Connector] A piece of data appear in both full data and binlog data.

3

**Describe the bug(Please use English)** When full data is being read and a piece of data is inserted, this data will appear in both full data and binlog data. **Environment...

MaoHJ-Official

[mysql] Support docker image of ARM chip

2

minchowang