layhuts created FLINK-35783:
-------------------------------
Summary: Flink CDC Could not start the yaml Job
Key: FLINK-35783
URL: https://issues.apache.org/jira/browse/FLINK-35783
Project: Flink
Issue Type: Bug
Components: Flink CDC
Affects Versions: cdc-3.1.1
Reporter: layhuts
* flink版本1.19.1
* flink CDC版本3.1.1
* 在${FLINK_HOME}/lib下增加了 mysql-connector-java-8.0.27.jar 和
flink-sql-connector-mysql-cdc-3.1.1.jar
* 在flink-cdc/lib下增加了flink-cdc-pipeline-connector-mysql-3.1.1.jar 和
flink-cdc-pipeline-connector-doris-3.1.1.jar
第一次使用
{code:java}
bin/flink-cdc.sh ***.yaml {code}
提交作业提示java.lang.NoClassDefFoundError:org/apache/flink/cdc/runtime/typeutils/EventTypeInfo
{code:java}
Caused by: java.lang.NoClassDefFoundError:
org/apache/flink/cdc/runtime/typeutils/EventTypeInfo at
java.lang.Class.getDeclaredFields0(Native Method) at
java.lang.Class.privateGetDeclaredFields(Class.java:2583) at
java.lang.Class.getDeclaredField(Class.java:2068) at
java.io.ObjectStreamClass.getDeclaredSUID(ObjectStreamClass.java:1872) at
java.io.ObjectStreamClass.access$700(ObjectStreamClass.java:79) at
java.io.ObjectStreamClass$3.run(ObjectStreamClass.java:506) at
java.io.ObjectStreamClass$3.run(ObjectStreamClass.java:494) at
java.security.AccessController.doPrivileged(Native Method) at
java.io.ObjectStreamClass.<init>(ObjectStreamClass.java:494) at
java.io.ObjectStreamClass.lookup(ObjectStreamClass.java:391) at
java.io.ObjectStreamClass.initNonProxy(ObjectStreamClass.java:681) at
java.io.ObjectInputStream.readNonProxyDesc(ObjectInputStream.java:2028) at
java.io.ObjectInputStream.readClassDesc(ObjectInputStream.java:1875) at
java.io.ObjectInputStream.readNonProxyDesc(ObjectInputStream.java:2028) at
java.io.ObjectInputStream.readClassDesc(ObjectInputStream.java:1875) at
java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2209) at
java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1692) at
java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2454) at
java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2378) at
java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2236) at
java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1692) at
java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2454) at
java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2378) at
java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2236) at
java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1692) at
java.io.ObjectInputStream.readObject(ObjectInputStream.java:508) at
java.io.ObjectInputStream.readObject(ObjectInputStream.java:466) at
org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:539)
at
org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:527)
at
org.apache.flink.util.SerializedValue.deserializeValue(SerializedValue.java:67)
at
org.apache.flink.runtime.operators.coordination.OperatorCoordinatorHolder.create(OperatorCoordinatorHolder.java:496)
at
org.apache.flink.runtime.executiongraph.ExecutionJobVertex.createOperatorCoordinatorHolder(ExecutionJobVertex.java:294)
at
org.apache.flink.runtime.executiongraph.ExecutionJobVertex.<init>(ExecutionJobVertex.java:173)
... 19 more Caused by: java.lang.ClassNotFoundException:
org.apache.flink.cdc.runtime.typeutils.EventTypeInfo at
java.net.URLClassLoader.findClass(URLClassLoader.java:387) at
java.lang.ClassLoader.loadClass(ClassLoader.java:418) at
sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:355) at
java.lang.ClassLoader.loadClass(ClassLoader.java:351) ... 52 more {code}
按照提示在${FLINK_HOME}/lib下增加了 flink-cdc-runtime-3.1.1.jar 后再次运行出现如下问题：
{code:java}
Exception in thread "main" org.apache.flink.util.FlinkException: Failed to
execute job 'Sync mid_cloud Database to Doris'.
at
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.executeAsync(StreamExecutionEnvironment.java:2455)
at
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.executeAsync(StreamExecutionEnvironment.java:2421)
at
org.apache.flink.cdc.composer.flink.FlinkPipelineExecution.execute(FlinkPipelineExecution.java:43)
at org.apache.flink.cdc.cli.CliExecutor.run(CliExecutor.java:74)
at org.apache.flink.cdc.cli.CliFrontend.main(CliFrontend.java:71)
Caused by: java.lang.RuntimeException:
org.apache.flink.runtime.client.JobInitializationException: Could not start the
JobMaster.
at org.apache.flink.util.ExceptionUtils.rethrow(ExceptionUtils.java:321)
at
org.apache.flink.util.function.FunctionUtils.lambda$uncheckedFunction$2(FunctionUtils.java:75)
at
java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616)
at
java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591)
at
java.util.concurrent.CompletableFuture$Completion.exec(CompletableFuture.java:457)
at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
at
java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1067)
at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1703)
at
java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:172)
Caused by: org.apache.flink.runtime.client.JobInitializationException: Could
not start the JobMaster.
at
org.apache.flink.runtime.jobmaster.DefaultJobMasterServiceProcess.lambda$new$0(DefaultJobMasterServiceProcess.java:97)
at
java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
at
java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
at
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
at
java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1609)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:750)
Caused by: java.util.concurrent.CompletionException:
java.lang.RuntimeException: org.apache.flink.runtime.JobException: Cannot
instantiate the coordinator for operator Source: Flink CDC Event Source: mysql
-> SchemaOperator -> PrePartition
at
java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:273)
at
java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:280)
at
java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1606)
... 3 more
Caused by: java.lang.RuntimeException: org.apache.flink.runtime.JobException:
Cannot instantiate the coordinator for operator Source: Flink CDC Event Source:
mysql -> SchemaOperator -> PrePartition
at org.apache.flink.util.ExceptionUtils.rethrow(ExceptionUtils.java:321)
at
org.apache.flink.util.function.FunctionUtils.lambda$uncheckedSupplier$4(FunctionUtils.java:114)
at
java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1604)
... 3 more
Caused by: org.apache.flink.runtime.JobException: Cannot instantiate the
coordinator for operator Source: Flink CDC Event Source: mysql ->
SchemaOperator -> PrePartition
at
org.apache.flink.runtime.executiongraph.ExecutionJobVertex.<init>(ExecutionJobVertex.java:182)
at
org.apache.flink.runtime.executiongraph.ExecutionJobVertex$Factory.createExecutionJobVertex(ExecutionJobVertex.java:671)
at
org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.attachJobVertices(DefaultExecutionGraph.java:860)
at
org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.attachJobGraph(DefaultExecutionGraph.java:833)
at
org.apache.flink.runtime.executiongraph.DefaultExecutionGraphBuilder.buildGraph(DefaultExecutionGraphBuilder.java:221)
at
org.apache.flink.runtime.scheduler.DefaultExecutionGraphFactory.createAndRestoreExecutionGraph(DefaultExecutionGraphFactory.java:173)
at
org.apache.flink.runtime.scheduler.SchedulerBase.createAndRestoreExecutionGraph(SchedulerBase.java:381)
at
org.apache.flink.runtime.scheduler.SchedulerBase.<init>(SchedulerBase.java:224)
at
org.apache.flink.runtime.scheduler.DefaultScheduler.<init>(DefaultScheduler.java:140)
at
org.apache.flink.runtime.scheduler.DefaultSchedulerFactory.createInstance(DefaultSchedulerFactory.java:162)
at
org.apache.flink.runtime.jobmaster.DefaultSlotPoolServiceSchedulerFactory.createScheduler(DefaultSlotPoolServiceSchedulerFactory.java:121)
at
org.apache.flink.runtime.jobmaster.JobMaster.createScheduler(JobMaster.java:379)
at org.apache.flink.runtime.jobmaster.JobMaster.<init>(JobMaster.java:356)
at
org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.internalCreateJobMasterService(DefaultJobMasterServiceFactory.java:128)
at
org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.lambda$createJobMasterService$0(DefaultJobMasterServiceFactory.java:100)
at
org.apache.flink.util.function.FunctionUtils.lambda$uncheckedSupplier$4(FunctionUtils.java:112)
... 4 more
Caused by: java.io.IOException: unexpected exception type
at java.io.ObjectStreamClass.throwMiscException(ObjectStreamClass.java:1751)
at java.io.ObjectStreamClass.invokeReadResolve(ObjectStreamClass.java:1281)
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2245)
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1692)
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2454)
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2378)
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2236)
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1692)
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2454)
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2378)
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2236)
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1692)
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:508)
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:466)
at
org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:539)
at
org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:527)
at
org.apache.flink.util.SerializedValue.deserializeValue(SerializedValue.java:67)
at
org.apache.flink.runtime.operators.coordination.OperatorCoordinatorHolder.create(OperatorCoordinatorHolder.java:496)
at
org.apache.flink.runtime.executiongraph.ExecutionJobVertex.createOperatorCoordinatorHolder(ExecutionJobVertex.java:294)
at
org.apache.flink.runtime.executiongraph.ExecutionJobVertex.<init>(ExecutionJobVertex.java:173)
... 19 more
Caused by: java.lang.reflect.InvocationTargetException
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at java.lang.invoke.SerializedLambda.readResolve(SerializedLambda.java:230)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at java.io.ObjectStreamClass.invokeReadResolve(ObjectStreamClass.java:1275)
... 37 more
Caused by: java.lang.BootstrapMethodError: java.lang.IllegalAccessError: tried
to access class
org.apache.flink.cdc.connectors.mysql.source.MySqlSource$RecordEmitterSupplier
from class org.apache.flink.cdc.connectors.mysql.source.MySqlDataSource
at
org.apache.flink.cdc.connectors.mysql.source.MySqlDataSource.$deserializeLambda$(MySqlDataSource.java:33)
... 47 more
Caused by: java.lang.IllegalAccessError: tried to access class
org.apache.flink.cdc.connectors.mysql.source.MySqlSource$RecordEmitterSupplier
from class org.apache.flink.cdc.connectors.mysql.source.MySqlDataSource
... 48 more {code}
请问是否版本冲突，该如何解决
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
