flink-cdc

flink-cdc copied to clipboard

Invalid Java object for schema type INT64: class java.lang.String for field: "null"

3

**Describe the bug(Please use English)** A clear and concise description of what the bug is. **Environment :** - Flink version : 1.14.4 - Flink CDC version: 2.3 - Database and...

hehetown

**Describe the bug(Please use English)** insert mysql cdc table error : Could not execute SQL statement. Reason: org.apache.flink.table.api.ValidationException: SQL validation failed. null **Environment :** - flink-1.13.2 - Flink CDC version:...

ddfeiyu

Flink job will not stop when the mysql database becomes unavailable.

5

**Is your feature request related to a problem? Please describe.** I submit a flink job that reads from a mysql database and writes to a kafka cluster by mysql cdc...

ruanhang1993

**Describe the bug(Please use English)** 2022-07-22 10:36:21 java.lang.RuntimeException: One or more fetchers have encountered exception at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcherManager.checkErrors(SplitFetcherManager.java:223) at org.apache.flink.connector.base.source.reader.SourceReaderBase.getNextFetch(SourceReaderBase.java:154) at org.apache.flink.connector.base.source.reader.SourceReaderBase.pollNext(SourceReaderBase.java:116) at org.apache.flink.streaming.api.operators.SourceOperator.emitNext(SourceOperator.java:305) at org.apache.flink.streaming.runtime.io.StreamTaskSourceInput.emitNext(StreamTaskSourceInput.java:69) at org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:66) at org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:423) at...

nayoaixgnat

Overlapping definitions with PostgreSQL JDBC driver

1

When using both `postgresql` and `flink-connector-postgres-cdc` in a project as follows: ``` org.postgresql postgresql ${postgresql.version} org.apache.flink flink-connector-jdbc_${scala.binary.version} ${flink.version} com.alibaba.ververica flink-connector-postgres-cdc 1.1.0 ``` I'm getting this output during build/packaging: ``` [WARNING]...

sebasmagri

cause Could not find any factory for identifier 'sqlserver-cdc' that implements 'org.apache.flink.table.factories.DynamicTableFactory' in the classpath.

2

**Describe the bug(Please use English)** A clear and concise description of what the bug is. **Environment :** - Flink version : 1.14.4 - Flink CDC version: flink-sql-connector-sqlserver-cdc-2.2.1.jar - Database and...

algorizm

[Mysql]coding problem lead to chinese garbled

1

**Describe the bug(Please use English)** A clear and concise description of what the bug is. **Environment :** - Flink version : 1.13.6 - Flink CDC version: 2.1.1 - Database and...

yangyin666

When multiple jobs use the same slot name, some job may not get the incremental change.

fsk119

Support for Flink 1.15

4

Hello! Are there any plans in the near future to support version 1.15 of Flink?

tigrulya-exe

**Describe the bug(Please use English)** A clear and concise description of what the bug is. **Environment :** - Flink version : 1.15.0 - Flink CDC version: 2.2.1 - Database and...

zhaoyangjun0328