taier 1.10
chunjun master
yarnper模式
flink lib 1.12
mysql2mysql离线同步可以提交到yarn并且同步成功
mysqlbinlog2kafka实时同步失败，
json如下：
{
"parser": {
"targetMap": {
"type": 37,
"sourceId": 4
},
"sourceMap": {
"sourceId": 5,
"collectType": 0,
"rdbmsDaType": 1,
"allTable": false,
"cat": [
1,
2,
3
],
"multipleTable": false,
"type": 1,
"pavingData": false,
"table": [
"src_test"
]
},
"setting": {
"readerChannel": "1",
"isStream": true,
"isRestore": true,
"writerChannel": 1,
"speed": -1
}
},
"createModel": 1,
"job": {
"job": {
"content": [
{
"reader": {
"parameter": {
"password": "123456",
"port": 33061,
"cat": "insert,update,delete",
"host": "10.136.106.163",
"jdbcUrl": "jdbc:mysql://*:33061/test",
"start": {},
"pavingData": false,
"table": [
"src_test"
],
"username": "root"
},
"name": "binlogreader"
},
"writer": {
"parameter": {
"producerSettings": {
"zookeeper.connect": "",
"bootstrap.servers": "node2:9092"
},
"dataCompelOrder": false,
"topic": "student10"
},
"name": "kafkawriter"
}
}
],
"setting": {
"speed": {
"channel": 1,
"readerChannel": 1,
"writerChannel": 1,
"bytes": -1048576
},
"restore": {
"isRestore": false,
"isStream": false
}
}
}
}
}
报错问题如下：
org.apache.flink.util.FlinkException: JobMaster for job 68f9f11e7254b9da4eb80dd8eb7c1943 failed.
at org.apache.flink.runtime.dispatcher.Dispatcher.jobMasterFailed(Dispatcher.java:891) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.dispatcher.Dispatcher.dispatcherJobFailed(Dispatcher.java:461) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.dispatcher.Dispatcher.handleDispatcherJobResult(Dispatcher.java:443) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.dispatcher.Dispatcher.lambda$runJob$3(Dispatcher.java:422) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at java.util.concurrent.CompletableFuture.uniHandle(CompletableFuture.java:822) ~[?:1.8.0_211]
at java.util.concurrent.CompletableFuture$UniHandle.tryFire(CompletableFuture.java:797) ~[?:1.8.0_211]
at java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:442) ~[?:1.8.0_211]
at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRunAsync(AkkaRpcActor.java:440) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:208) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:77) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:158) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:26) [flink-dist_2.11-1.12.7.jar:1.12.7]
at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:21) [flink-dist_2.11-1.12.7.jar:1.12.7]
at scala.PartialFunction$class.applyOrElse(PartialFunction.scala:123) [flink-dist_2.11-1.12.7.jar:1.12.7]
at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:21) [flink-dist_2.11-1.12.7.jar:1.12.7]
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:170) [flink-dist_2.11-1.12.7.jar:1.12.7]
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) [flink-dist_2.11-1.12.7.jar:1.12.7]
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) [flink-dist_2.11-1.12.7.jar:1.12.7]
at akka.actor.Actor$class.aroundReceive(Actor.scala:517) [flink-dist_2.11-1.12.7.jar:1.12.7]
at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:225) [flink-dist_2.11-1.12.7.jar:1.12.7]
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:592) [flink-dist_2.11-1.12.7.jar:1.12.7]
at akka.actor.ActorCell.invoke(ActorCell.scala:561) [flink-dist_2.11-1.12.7.jar:1.12.7]
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258) [flink-dist_2.11-1.12.7.jar:1.12.7]
at akka.dispatch.Mailbox.run(Mailbox.scala:225) [flink-dist_2.11-1.12.7.jar:1.12.7]
at akka.dispatch.Mailbox.exec(Mailbox.scala:235) [flink-dist_2.11-1.12.7.jar:1.12.7]
at akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) [flink-dist_2.11-1.12.7.jar:1.12.7]
at akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) [flink-dist_2.11-1.12.7.jar:1.12.7]
at akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) [flink-dist_2.11-1.12.7.jar:1.12.7]
at akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) [flink-dist_2.11-1.12.7.jar:1.12.7]
Caused by: org.apache.flink.runtime.client.JobInitializationException: Could not instantiate JobManager.
at org.apache.flink.runtime.dispatcher.Dispatcher.lambda$createJobManagerRunner$5(Dispatcher.java:488) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1590) ~[?:1.8.0_211]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_211]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_211]
at java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_211]
Caused by: org.apache.flink.runtime.client.JobExecutionException: Cannot initialize task 'Source: binlogsourcefactory': Loading the input/output formats failed:
at org.apache.flink.runtime.executiongraph.ExecutionGraphBuilder.buildGraph(ExecutionGraphBuilder.java:293) ~[flinkx-core-master.jar:1.12.7]
at org.apache.flink.runtime.scheduler.SchedulerBase.createExecutionGraph(SchedulerBase.java:322) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.scheduler.SchedulerBase.createAndRestoreExecutionGraph(SchedulerBase.java:276) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.scheduler.SchedulerBase.(SchedulerBase.java:249) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.scheduler.DefaultScheduler.(DefaultScheduler.java:133) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.scheduler.DefaultSchedulerFactory.createInstance(DefaultSchedulerFactory.java:111) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.jobmaster.JobMaster.createScheduler(JobMaster.java:342) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.jobmaster.JobMaster.(JobMaster.java:327) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.createJobMasterService(DefaultJobMasterServiceFactory.java:95) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.createJobMasterService(DefaultJobMasterServiceFactory.java:39) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.jobmaster.JobManagerRunnerImpl.(JobManagerRunnerImpl.java:163) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.dispatcher.DefaultJobManagerRunnerFactory.createJobManagerRunner(DefaultJobManagerRunnerFactory.java:86) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.dispatcher.Dispatcher.lambda$createJobManagerRunner$5(Dispatcher.java:472) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1590) ~[?:1.8.0_211]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_211]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_211]
at java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_211]
Caused by: java.lang.Exception: Loading the input/output formats failed:
at org.apache.flink.runtime.jobgraph.InputOutputFormatVertex.initInputOutputformatContainer(InputOutputFormatVertex.java:172) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.jobgraph.InputOutputFormatVertex.initializeOnMaster(InputOutputFormatVertex.java:57) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.executiongraph.ExecutionGraphBuilder.buildGraph(ExecutionGraphBuilder.java:289) ~[flinkx-core-master.jar:1.12.7]
at org.apache.flink.runtime.scheduler.SchedulerBase.createExecutionGraph(SchedulerBase.java:322) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.scheduler.SchedulerBase.createAndRestoreExecutionGraph(SchedulerBase.java:276) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.scheduler.SchedulerBase.(SchedulerBase.java:249) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.scheduler.DefaultScheduler.(DefaultScheduler.java:133) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.scheduler.DefaultSchedulerFactory.createInstance(DefaultSchedulerFactory.java:111) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.jobmaster.JobMaster.createScheduler(JobMaster.java:342) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.jobmaster.JobMaster.(JobMaster.java:327) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.createJobMasterService(DefaultJobMasterServiceFactory.java:95) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.createJobMasterService(DefaultJobMasterServiceFactory.java:39) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.jobmaster.JobManagerRunnerImpl.(JobManagerRunnerImpl.java:163) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.dispatcher.DefaultJobManagerRunnerFactory.createJobManagerRunner(DefaultJobManagerRunnerFactory.java:86) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.dispatcher.Dispatcher.lambda$createJobManagerRunner$5(Dispatcher.java:472) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1590) ~[?:1.8.0_211]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_211]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_211]
at java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_211]
Caused by: java.lang.RuntimeException: Deserializing the input/output formats failed: com/google/protobuf/MessageOrBuilder
at org.apache.flink.runtime.jobgraph.InputOutputFormatContainer.(InputOutputFormatContainer.java:69) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.jobgraph.InputOutputFormatVertex.initInputOutputformatContainer(InputOutputFormatVertex.java:168) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.jobgraph.InputOutputFormatVertex.initializeOnMaster(InputOutputFormatVertex.java:57) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.executiongraph.ExecutionGraphBuilder.buildGraph(ExecutionGraphBuilder.java:289) ~[flinkx-core-master.jar:1.12.7]
at org.apache.flink.runtime.scheduler.SchedulerBase.createExecutionGraph(SchedulerBase.java:322) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.scheduler.SchedulerBase.createAndRestoreExecutionGraph(SchedulerBase.java:276) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.scheduler.SchedulerBase.(SchedulerBase.java:249) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.scheduler.DefaultScheduler.(DefaultScheduler.java:133) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.scheduler.DefaultSchedulerFactory.createInstance(DefaultSchedulerFactory.java:111) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.jobmaster.JobMaster.createScheduler(JobMaster.java:342) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.jobmaster.JobMaster.(JobMaster.java:327) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.createJobMasterService(DefaultJobMasterServiceFactory.java:95) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.createJobMasterService(DefaultJobMasterServiceFactory.java:39) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.jobmaster.JobManagerRunnerImpl.(JobManagerRunnerImpl.java:163) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.dispatcher.DefaultJobManagerRunnerFactory.createJobManagerRunner(DefaultJobManagerRunnerFactory.java:86) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.dispatcher.Dispatcher.lambda$createJobManagerRunner$5(Dispatcher.java:472) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1590) ~[?:1.8.0_211]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_211]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_211]
at java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_211]
Caused by: java.lang.NoClassDefFoundError: com/google/protobuf/MessageOrBuilder
at java.lang.ClassLoader.defineClass1(Native Method) ~[?:1.8.0_211]
at java.lang.ClassLoader.defineClass(ClassLoader.java:763) ~[?:1.8.0_211]
at java.security.SecureClassLoader.defineClass(SecureClassLoader.java:142) ~[?:1.8.0_211]
at java.net.URLClassLoader.defineClass(URLClassLoader.java:468) ~[?:1.8.0_211]
at java.net.URLClassLoader.access$100(URLClassLoader.java:74) ~[?:1.8.0_211]
at java.net.URLClassLoader$1.run(URLClassLoader.java:369) ~[?:1.8.0_211]
at java.net.URLClassLoader$1.run(URLClassLoader.java:363) ~[?:1.8.0_211]
at java.security.AccessController.doPrivileged(Native Method) ~[?:1.8.0_211]
at java.net.URLClassLoader.findClass(URLClassLoader.java:362) ~[?:1.8.0_211]
at java.lang.ClassLoader.loadClass(ClassLoader.java:424) ~[?:1.8.0_211]
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:349) ~[?:1.8.0_211]
at java.lang.ClassLoader.loadClass(ClassLoader.java:357) ~[?:1.8.0_211]
at java.lang.ClassLoader.defineClass1(Native Method) ~[?:1.8.0_211]
at java.lang.ClassLoader.defineClass(ClassLoader.java:763) ~[?:1.8.0_211]
at java.security.SecureClassLoader.defineClass(SecureClassLoader.java:142) ~[?:1.8.0_211]
at java.net.URLClassLoader.defineClass(URLClassLoader.java:468) ~[?:1.8.0_211]
at java.net.URLClassLoader.access$100(URLClassLoader.java:74) ~[?:1.8.0_211]
at java.net.URLClassLoader$1.run(URLClassLoader.java:369) ~[?:1.8.0_211]
at java.net.URLClassLoader$1.run(URLClassLoader.java:363) ~[?:1.8.0_211]
at java.security.AccessController.doPrivileged(Native Method) ~[?:1.8.0_211]
at java.net.URLClassLoader.findClass(URLClassLoader.java:362) ~[?:1.8.0_211]
at java.lang.ClassLoader.loadClass(ClassLoader.java:424) ~[?:1.8.0_211]
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:349) ~[?:1.8.0_211]
at java.lang.ClassLoader.loadClass(ClassLoader.java:357) ~[?:1.8.0_211]
at java.lang.Class.getDeclaredMethods0(Native Method) ~[?:1.8.0_211]
at java.lang.Class.privateGetDeclaredMethods(Class.java:2701) ~[?:1.8.0_211]
at java.lang.Class.getDeclaredMethod(Class.java:2128) ~[?:1.8.0_211]
at java.io.ObjectStreamClass.getPrivateMethod(ObjectStreamClass.java:1629) ~[?:1.8.0_211]
at java.io.ObjectStreamClass.access$1700(ObjectStreamClass.java:79) ~[?:1.8.0_211]
at java.io.ObjectStreamClass$3.run(ObjectStreamClass.java:520) ~[?:1.8.0_211]
at java.io.ObjectStreamClass$3.run(ObjectStreamClass.java:494) ~[?:1.8.0_211]
at java.security.AccessController.doPrivileged(Native Method) ~[?:1.8.0_211]
at java.io.ObjectStreamClass.(ObjectStreamClass.java:494) ~[?:1.8.0_211]
at java.io.ObjectStreamClass.lookup(ObjectStreamClass.java:391) ~[?:1.8.0_211]
at java.io.ObjectStreamClass.initNonProxy(ObjectStreamClass.java:681) ~[?:1.8.0_211]
at java.io.ObjectInputStream.readNonProxyDesc(ObjectInputStream.java:1885) ~[?:1.8.0_211]
at java.io.ObjectInputStream.readClassDesc(ObjectInputStream.java:1751) ~[?:1.8.0_211]
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2042) ~[?:1.8.0_211]
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1573) ~[?:1.8.0_211]
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2287) ~[?:1.8.0_211]
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2211) ~[?:1.8.0_211]
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2069) ~[?:1.8.0_211]
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1573) ~[?:1.8.0_211]
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2287) ~[?:1.8.0_211]
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2211) ~[?:1.8.0_211]
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2069) ~[?:1.8.0_211]
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1573) ~[?:1.8.0_211]
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:431) ~[?:1.8.0_211]
at java.util.HashMap.readObject(HashMap.java:1412) ~[?:1.8.0_211]
at sun.reflect.GeneratedMethodAccessor4.invoke(Unknown Source) ~[?:?]
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:1.8.0_211]
at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_211]
at java.io.ObjectStreamClass.invokeReadObject(ObjectStreamClass.java:1170) ~[?:1.8.0_211]
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2178) ~[?:1.8.0_211]
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2069) ~[?:1.8.0_211]
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1573) ~[?:1.8.0_211]
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2287) ~[?:1.8.0_211]
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2211) ~[?:1.8.0_211]
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2069) ~[?:1.8.0_211]
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1573) ~[?:1.8.0_211]
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2287) ~[?:1.8.0_211]
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2211) ~[?:1.8.0_211]
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2069) ~[?:1.8.0_211]
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1573) ~[?:1.8.0_211]
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:431) ~[?:1.8.0_211]
at org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:615) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:600) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:587) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.util.InstantiationUtil.readObjectFromConfig(InstantiationUtil.java:541) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.operators.util.TaskConfig.getStubWrapper(TaskConfig.java:304) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.jobgraph.InputOutputFormatContainer.(InputOutputFormatContainer.java:66) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.jobgraph.InputOutputFormatVertex.initInputOutputformatContainer(InputOutputFormatVertex.java:168) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.jobgraph.InputOutputFormatVertex.initializeOnMaster(InputOutputFormatVertex.java:57) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.executiongraph.ExecutionGraphBuilder.buildGraph(ExecutionGraphBuilder.java:289) ~[flinkx-core-master.jar:1.12.7]
at org.apache.flink.runtime.scheduler.SchedulerBase.createExecutionGraph(SchedulerBase.java:322) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.scheduler.SchedulerBase.createAndRestoreExecutionGraph(SchedulerBase.java:276) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.scheduler.SchedulerBase.(SchedulerBase.java:249) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.scheduler.DefaultScheduler.(DefaultScheduler.java:133) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.scheduler.DefaultSchedulerFactory.createInstance(DefaultSchedulerFactory.java:111) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.jobmaster.JobMaster.createScheduler(JobMaster.java:342) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.jobmaster.JobMaster.(JobMaster.java:327) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.createJobMasterService(DefaultJobMasterServiceFactory.java:95) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.createJobMasterService(DefaultJobMasterServiceFactory.java:39) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.jobmaster.JobManagerRunnerImpl.(JobManagerRunnerImpl.java:163) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.dispatcher.DefaultJobManagerRunnerFactory.createJobManagerRunner(DefaultJobManagerRunnerFactory.java:86) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.dispatcher.Dispatcher.lambda$createJobManagerRunner$5(Dispatcher.java:472) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1590) ~[?:1.8.0_211]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_211]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_211]
at java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_211]
Caused by: java.lang.ClassNotFoundException: com.google.protobuf.MessageOrBuilder
at java.net.URLClassLoader.findClass(URLClassLoader.java:382) ~[?:1.8.0_211]
at java.lang.ClassLoader.loadClass(ClassLoader.java:424) ~[?:1.8.0_211]
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:349) ~[?:1.8.0_211]
at java.lang.ClassLoader.loadClass(ClassLoader.java:357) ~[?:1.8.0_211]
at java.lang.ClassLoader.defineClass1(Native Method) ~[?:1.8.0_211]
at java.lang.ClassLoader.defineClass(ClassLoader.java:763) ~[?:1.8.0_211]
at java.security.SecureClassLoader.defineClass(SecureClassLoader.java:142) ~[?:1.8.0_211]
at java.net.URLClassLoader.defineClass(URLClassLoader.java:468) ~[?:1.8.0_211]
at java.net.URLClassLoader.access$100(URLClassLoader.java:74) ~[?:1.8.0_211]
at java.net.URLClassLoader$1.run(URLClassLoader.java:369) ~[?:1.8.0_211]
at java.net.URLClassLoader$1.run(URLClassLoader.java:363) ~[?:1.8.0_211]
at java.security.AccessController.doPrivileged(Native Method) ~[?:1.8.0_211]
at java.net.URLClassLoader.findClass(URLClassLoader.java:362) ~[?:1.8.0_211]
at java.lang.ClassLoader.loadClass(ClassLoader.java:424) ~[?:1.8.0_211]
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:349) ~[?:1.8.0_211]
at java.lang.ClassLoader.loadClass(ClassLoader.java:357) ~[?:1.8.0_211]
at java.lang.ClassLoader.defineClass1(Native Method) ~[?:1.8.0_211]
at java.lang.ClassLoader.defineClass(ClassLoader.java:763) ~[?:1.8.0_211]
at java.security.SecureClassLoader.defineClass(SecureClassLoader.java:142) ~[?:1.8.0_211]
at java.net.URLClassLoader.defineClass(URLClassLoader.java:468) ~[?:1.8.0_211]
at java.net.URLClassLoader.access$100(URLClassLoader.java:74) ~[?:1.8.0_211]
at java.net.URLClassLoader$1.run(URLClassLoader.java:369) ~[?:1.8.0_211]
at java.net.URLClassLoader$1.run(URLClassLoader.java:363) ~[?:1.8.0_211]
at java.security.AccessController.doPrivileged(Native Method) ~[?:1.8.0_211]
at java.net.URLClassLoader.findClass(URLClassLoader.java:362) ~[?:1.8.0_211]
at java.lang.ClassLoader.loadClass(ClassLoader.java:424) ~[?:1.8.0_211]
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:349) ~[?:1.8.0_211]
at java.lang.ClassLoader.loadClass(ClassLoader.java:357) ~[?:1.8.0_211]
at java.lang.Class.getDeclaredMethods0(Native Method) ~[?:1.8.0_211]
at java.lang.Class.privateGetDeclaredMethods(Class.java:2701) ~[?:1.8.0_211]
at java.lang.Class.getDeclaredMethod(Class.java:2128) ~[?:1.8.0_211]
at java.io.ObjectStreamClass.getPrivateMethod(ObjectStreamClass.java:1629) ~[?:1.8.0_211]
at java.io.ObjectStreamClass.access$1700(ObjectStreamClass.java:79) ~[?:1.8.0_211]
at java.io.ObjectStreamClass$3.run(ObjectStreamClass.java:520) ~[?:1.8.0_211]
at java.io.ObjectStreamClass$3.run(ObjectStreamClass.java:494) ~[?:1.8.0_211]
at java.security.AccessController.doPrivileged(Native Method) ~[?:1.8.0_211]
at java.io.ObjectStreamClass.(ObjectStreamClass.java:494) ~[?:1.8.0_211]
at java.io.ObjectStreamClass.lookup(ObjectStreamClass.java:391) ~[?:1.8.0_211]
at java.io.ObjectStreamClass.initNonProxy(ObjectStreamClass.java:681) ~[?:1.8.0_211]
at java.io.ObjectInputStream.readNonProxyDesc(ObjectInputStream.java:1885) ~[?:1.8.0_211]
at java.io.ObjectInputStream.readClassDesc(ObjectInputStream.java:1751) ~[?:1.8.0_211]
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2042) ~[?:1.8.0_211]
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1573) ~[?:1.8.0_211]
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2287) ~[?:1.8.0_211]
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2211) ~[?:1.8.0_211]
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2069) ~[?:1.8.0_211]
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1573) ~[?:1.8.0_211]
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2287) ~[?:1.8.0_211]
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2211) ~[?:1.8.0_211]
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2069) ~[?:1.8.0_211]
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1573) ~[?:1.8.0_211]
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:431) ~[?:1.8.0_211]
at java.util.HashMap.readObject(HashMap.java:1412) ~[?:1.8.0_211]
at sun.reflect.GeneratedMethodAccessor4.invoke(Unknown Source) ~[?:?]
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:1.8.0_211]
at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_211]
at java.io.ObjectStreamClass.invokeReadObject(ObjectStreamClass.java:1170) ~[?:1.8.0_211]
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2178) ~[?:1.8.0_211]
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2069) ~[?:1.8.0_211]
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1573) ~[?:1.8.0_211]
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2287) ~[?:1.8.0_211]
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2211) ~[?:1.8.0_211]
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2069) ~[?:1.8.0_211]
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1573) ~[?:1.8.0_211]
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2287) ~[?:1.8.0_211]
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2211) ~[?:1.8.0_211]
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2069) ~[?:1.8.0_211]
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1573) ~[?:1.8.0_211]
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:431) ~[?:1.8.0_211]
at org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:615) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:600) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:587) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.util.InstantiationUtil.readObjectFromConfig(InstantiationUtil.java:541) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.operators.util.TaskConfig.getStubWrapper(TaskConfig.java:304) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.jobgraph.InputOutputFormatContainer.(InputOutputFormatContainer.java:66) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.jobgraph.InputOutputFormatVertex.initInputOutputformatContainer(InputOutputFormatVertex.java:168) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.jobgraph.InputOutputFormatVertex.initializeOnMaster(InputOutputFormatVertex.java:57) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.executiongraph.ExecutionGraphBuilder.buildGraph(ExecutionGraphBuilder.java:289) ~[flinkx-core-master.jar:1.12.7]
at org.apache.flink.runtime.scheduler.SchedulerBase.createExecutionGraph(SchedulerBase.java:322) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.scheduler.SchedulerBase.createAndRestoreExecutionGraph(SchedulerBase.java:276) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.scheduler.SchedulerBase.(SchedulerBase.java:249) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.scheduler.DefaultScheduler.(DefaultScheduler.java:133) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.scheduler.DefaultSchedulerFactory.createInstance(DefaultSchedulerFactory.java:111) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.jobmaster.JobMaster.createScheduler(JobMaster.java:342) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.jobmaster.JobMaster.(JobMaster.java:327) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.createJobMasterService(DefaultJobMasterServiceFactory.java:95) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.createJobMasterService(DefaultJobMasterServiceFactory.java:39) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.jobmaster.JobManagerRunnerImpl.(JobManagerRunnerImpl.java:163) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.dispatcher.DefaultJobManagerRunnerFactory.createJobManagerRunner(DefaultJobManagerRunnerFactory.java:86) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at org.apache.flink.runtime.dispatcher.Dispatcher.lambda$createJobManagerRunner$5(Dispatcher.java:472) ~[flink-dist_2.11-1.12.7.jar:1.12.7]
at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1590) ~[?:1.8.0_211]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_211]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_211]
at java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_211]
DTStack
