flink-cdc icon indicating copy to clipboard operation
flink-cdc copied to clipboard

The program encountered a blockage preventing it from reading snapshot data from mysql-cdc [Bug]

Open gongzexin opened this issue 1 year ago • 1 comments

Search before asking

  • [X] I searched in the issues and found nothing similar.

Flink version

1.14.5

Flink CDC version

2.3

Database and its version

mysql 5.7.41

Minimal reproduce step

flink config:

taskmanager.memory.process.size: 2 gb taskmanager.numberOfTaskSlots: 1 parallelism.default: 1

mysql table schema and data:

The data must be kept confidential. If needed, please contact me at [email protected].

What did you expect to see?

Read the snapshot data of this table normally.

What did you see instead?

The snapshot data query was successful, but there was no return value when calling the method com.ververica.cdc.connectors.mysql.debezium.task.MySqlSnapshotSplitReadTask.readField(ResultSet, int, Column, Table).

Anything else?

No response

Are you willing to submit a PR?

  • [X] I'm willing to submit a PR!

gongzexin avatar May 29 '23 09:05 gongzexin

The code part you provide is about getting a field from the ResultSet. It is helpful to look at the thread dump and find where the problem is hanging on.

ruanhang1993 avatar Feb 04 '24 12:02 ruanhang1993

Closing this issue as it has been migrated to Apache Jira.

PatrickRen avatar Apr 09 '24 06:04 PatrickRen