terrence created FLINK-38467:
--------------------------------
Summary: Caused by: java.lang.ClassCastException
Key: FLINK-38467
URL: https://issues.apache.org/jira/browse/FLINK-38467
Project: Flink
Issue Type: Bug
Components: Flink CDC
Affects Versions: cdc-3.5.0
Environment: mysql:8.0.31
doris-2.1.3-rc09
flink-1.19.0-bin-scala_2.12.tgz
flink-cdc-3.1.0-bin.tar.gz
flink-cdc-pipeline-connector-mysql-3.1.0.jar
flink-cdc-pipeline-connector-doris-3.1.0.jar
mysql-connector-java-8.0.27.jar
Reporter: terrence
{code:java}
./bin/flink-cdc.sh mysql-to-doris.yaml SLF4J: Class path contains multiple
SLF4J bindings.SLF4J: Found binding in
[jar:file:/Users/brin/work/tools/doris_build/doris-1fe1be/tools/flink-1.19.0/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]SLF4J:
Found binding in
[jar:file:/Users/brin/data/doris-runtime/flink/flink-1.19.0/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]SLF4J:
See http://www.slf4j.org/codes.html#multiple_bindings for an
explanation.SLF4J: Actual binding is of type
[org.apache.logging.slf4j.Log4jLoggerFactory]Exception in thread "main"
org.apache.flink.util.FlinkException: Failed to execute job 'Sync MySQL
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.base/java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:646)
at
java.base/java.util.concurrent.CompletableFuture$Completion.exec(CompletableFuture.java:483)
at java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:507)
at
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1491)
at java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:2073)
at
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:2035)
at
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:187)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.base/java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:863)
at
java.base/java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:841)
at
java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:510)
at
java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1773)
at
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
at
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
at java.base/java.lang.Thread.run(Thread.java:1570)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.base/java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:315)
at
java.base/java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:320)
at
java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1770)
... 3 moreCaused 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.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1768)
... 3 moreCaused 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 moreCaused by: java.lang.ClassCastException: cannot assign instance
of org.apache.doris.flink.cfg.DorisOptions to field
org.apache.flink.cdc.connectors.doris.sink.DorisMetadataApplier.dorisOptions of
type org.apache.doris.flink.cfg.DorisOptions in instance of
org.apache.flink.cdc.connectors.doris.sink.DorisMetadataApplier at
java.base/java.io.ObjectStreamClass$FieldReflector.setObjFieldValues(ObjectStreamClass.java:2102)
at
java.base/java.io.ObjectStreamClass$FieldReflector.checkObjectFieldValueTypes(ObjectStreamClass.java:2066)
at
java.base/java.io.ObjectStreamClass.checkObjFieldValueTypes(ObjectStreamClass.java:1355)
at
java.base/java.io.ObjectInputStream$FieldValues.defaultCheckFieldValues(ObjectInputStream.java:2682)
at
java.base/java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2483)
at
java.base/java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2269)
at
java.base/java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1747) at
java.base/java.io.ObjectInputStream$FieldValues.<init>(ObjectInputStream.java:2603)
at
java.base/java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2454)
at
java.base/java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2269)
at
java.base/java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1747) at
java.base/java.io.ObjectInputStream.readObject(ObjectInputStream.java:525) at
java.base/java.io.ObjectInputStream.readObject(ObjectInputStream.java:483) 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
{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
