flink-cdc
flink-cdc copied to clipboard
The program encountered a blockage preventing it from reading snapshot data from mysql-cdc [Bug]
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!
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.
Closing this issue as it has been migrated to Apache Jira.