[
https://issues.apache.org/jira/browse/FLINK-35783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
layhuts closed FLINK-35783.
---------------------------
Resolution: Done
> 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
> Priority: Major
>
> * 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)
