Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[Bug]数据同步时jobmanager报错 #11456

Open
2 tasks done
qwe123520 opened this issue Nov 5, 2024 · 3 comments
Open
2 tasks done

[Bug]数据同步时jobmanager报错 #11456

qwe123520 opened this issue Nov 5, 2024 · 3 comments
Labels
type/bug Something is wrong

Comments

@qwe123520
Copy link

What happened

jobmanager | 2024-11-05 03:00:53,854 ERROR org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Failed to create Source Enumerator for source Source: table_vi-dev[5]
jobmanager | java.lang.NoSuchMethodError: 'void io.debezium.jdbc.JdbcConnection.(io.debezium.config.Configuration, io.debezium.jdbc.JdbcConnection$ConnectionFactory)'
jobmanager | at com.ververica.cdc.connectors.mysql.debezium.DebeziumUtils.openJdbcConnection(DebeziumUtils.java:58) ~[sort-connector-mysql-cdc-v1.15-2.0.0.jar:2.3.0]
jobmanager | at com.ververica.cdc.connectors.mysql.MySqlValidator.validate(MySqlValidator.java:72) ~[sort-connector-mysql-cdc-v1.15-2.0.0.jar:2.3.0]
jobmanager | at org.apache.inlong.sort.mysql.source.MySqlSource.createEnumerator(MySqlSource.java:180) ~[sort-connector-mysql-cdc-v1.15-2.0.0.jar:2.3.0]
jobmanager | at org.apache.flink.runtime.source.coordinator.SourceCoordinator.start(SourceCoordinator.java:197) ~[flink-dist-1.15.4.jar:1.15.4]
jobmanager | at org.apache.flink.runtime.operators.coordination.RecreateOnResetOperatorCoordinator$DeferrableCoordinator.resetAndStart(RecreateOnResetOperatorCoordinator.java:394) ~[flink-dist-1.15.4.jar:1.15.4]
jobmanager | at org.apache.flink.runtime.operators.coordination.RecreateOnResetOperatorCoordinator.lambda$resetToCheckpoint$6(RecreateOnResetOperatorCoordinator.java:144) ~[flink-dist-1.15.4.jar:1.15.4]
jobmanager | at java.util.concurrent.CompletableFuture.uniWhenComplete(Unknown Source) ~[?:?]
jobmanager | at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(Unknown Source) ~[?:?]
jobmanager | at java.util.concurrent.CompletableFuture.postComplete(Unknown Source) ~[?:?]
jobmanager | at java.util.concurrent.CompletableFuture.complete(Unknown Source) ~[?:?]
jobmanager | at org.apache.flink.runtime.operators.coordination.ComponentClosingUtils.lambda$closeAsyncWithTimeout$0(ComponentClosingUtils.java:77) ~[flink-dist-1.15.4.jar:1.15.4]
jobmanager | at java.lang.Thread.run(Unknown Source) [?:?]

What you expected to happen

可以成功启动,并不报错

How to reproduce

mysql同步到mysql即可实现,使用docker部署模式

Environment

No response

InLong version

2.0.0

InLong Component

InLong Manager

Are you willing to submit PR?

  • Yes, I am willing to submit a PR!

Code of Conduct

@qwe123520 qwe123520 added the type/bug Something is wrong label Nov 5, 2024
Copy link

github-actions bot commented Nov 5, 2024

Hello @qwe123520, thank you for opening your first issue in InLong 🧡 We will respond as soon as possible ⏳
If this is a bug report, please provide screenshots or error logs for us to reproduce your issue, so we can do our best to fix it.
If you have any questions in the meantime, you can also ask us on the InLong Discussions 🔍

@fuweng11
Copy link
Contributor

fuweng11 commented Nov 6, 2024

May I ask if this real-time synchronization task was initiated through the InLong Manager or directly submitted to the Flink?

@qwe123520
Copy link
Author

通过inlong的taskmanager提交的,不是直接调用的fink

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
type/bug Something is wrong
Projects
None yet
Development

No branches or pull requests

2 participants