[
https://issues.apache.org/jira/browse/FLINK-27464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17541255#comment-17541255
]
Shengkai Fang commented on FLINK-27464:
---------------------------------------
+1 to use Flink CDC as the source, which is much powerful.
I notice you use the parent-first as the resolve order. For connector, you
should use the child-first.
> java.lang.NoClassDefFoundError
> ------------------------------
>
> Key: FLINK-27464
> URL: https://issues.apache.org/jira/browse/FLINK-27464
> Project: Flink
> Issue Type: Bug
> Components: Connectors / JDBC
> Affects Versions: 1.13.6
> Reporter: zhangxin
> Priority: Major
>
> used config classloader.resolve-order: parent-first
> at:
>
> Caused by: org.apache.flink.util.FlinkException: Global failure triggered by
> OperatorCoordinator for 'Source: Flink-IMS -> Map -> Sink: Unnamed' (operator
> cbc357ccb763df2852fee8c4fc7d55f2).
> at
> org.apache.flink.runtime.operators.coordination.OperatorCoordinatorHolder$LazyInitializedCoordinatorContext.failJob(OperatorCoordinatorHolder.java:553)
> at
> org.apache.flink.runtime.operators.coordination.RecreateOnResetOperatorCoordinator$QuiesceableContext.failJob(RecreateOnResetOperatorCoordinator.java:223)
> at
> org.apache.flink.runtime.source.coordinator.SourceCoordinatorContext.failJob(SourceCoordinatorContext.java:285)
> at
> org.apache.flink.runtime.source.coordinator.SourceCoordinator.start(SourceCoordinator.java:133)
> at
> org.apache.flink.runtime.operators.coordination.RecreateOnResetOperatorCoordinator$DeferrableCoordinator.resetAndStart(RecreateOnResetOperatorCoordinator.java:381)
> at
> org.apache.flink.runtime.operators.coordination.RecreateOnResetOperatorCoordinator.lambda$resetToCheckpoint$6(RecreateOnResetOperatorCoordinator.java:136)
> at
> java.util.concurrent.CompletableFuture.uniRun(CompletableFuture.java:719)
> at
> java.util.concurrent.CompletableFuture$UniRun.tryFire(CompletableFuture.java:701)
> at
> java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
> at
> java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
> at
> org.apache.flink.runtime.operators.coordination.ComponentClosingUtils.lambda$closeAsyncWithTimeout$0(ComponentClosingUtils.java:71)
> at java.lang.Thread.run(Thread.java:748)
> Caused by: java.lang.NoClassDefFoundError: com/zaxxer/hikari/HikariConfig
> at
> com.ververica.cdc.connectors.mysql.source.connection.PooledDataSourceFactory.createPooledDataSource(PooledDataSourceFactory.java:38)
> at
> com.ververica.cdc.connectors.mysql.source.connection.JdbcConnectionPools.getOrCreateConnectionPool(JdbcConnectionPools.java:51)
> at
> com.ververica.cdc.connectors.mysql.source.connection.JdbcConnectionFactory.connect(JdbcConnectionFactory.java:53)
> at io.debezium.jdbc.JdbcConnection.connection(JdbcConnection.java:872)
> at io.debezium.jdbc.JdbcConnection.connection(JdbcConnection.java:867)
> at io.debezium.jdbc.JdbcConnection.connect(JdbcConnection.java:413)
> at
> com.ververica.cdc.connectors.mysql.debezium.DebeziumUtils.openJdbcConnection(DebeziumUtils.java:62)
> at
> com.ververica.cdc.connectors.mysql.MySqlValidator.validate(MySqlValidator.java:68)
> at
> com.ververica.cdc.connectors.mysql.source.MySqlSource.createEnumerator(MySqlSource.java:156)
> at
> org.apache.flink.runtime.source.coordinator.SourceCoordinator.start(SourceCoordinator.java:129)
> ... 8 more
--
This message was sent by Atlassian Jira
(v8.20.7#820007)
