Мой проект SpringBoot не может запуститься, поскольку он интегрирует Flink ⇐ JAVA

[Anonymous]

Мой проект SpringBoot не может запуститься, поскольку он интегрирует Flink! Подскажите, что класс не найден, Но этот класс существует, Упаковка тоже имеется
=================== ==========Журнал===============================
2024-05-29 10:02:19,750 ИНФОРМАЦИЯ (AbstractBlobCache.java:251) — выключение BLOB-кэша
2024-05-29 10:02:19,748 ОШИБКА (SpringApplication.java:859) — Ошибка запуска приложения
java.lang.IllegalStateException: не удалось выполнить ApplicationRunner
в org.springframework.boot.SpringApplication.lambda$callRunner$6(SpringApplication.java:797)
в org.springframework. util.function.ThrowingConsumer.accept(ThrowingConsumer.java:66)
в org.springframework.util.function.ThrowingConsumer$1.accept(ThrowingConsumer.java:88)
в org.springframework.boot.SpringApplication .callRunner(SpringApplication.java:798)
в org.springframework.boot.SpringApplication.callRunner(SpringApplication.java:786)
в org.springframework.boot.SpringApplication.lambda$callRunners$3(SpringApplication. java:774)
в java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:184)
в java.base/java.util.stream.SortedOps$ SizedRefSortingSink.end(SortedOps.java:357)
в java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:510)
в java.base/java.util.stream. AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499)
в java.base/java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:151)
в java.base/java.util. stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:174)
в java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
в java.base/ java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:596)
в org.springframework.boot.SpringApplication.callRunners(SpringApplication.java:774)
в org.springframework.boot.SpringApplication. run(SpringApplication.java:342)
в org.springframework.boot.SpringApplication.run(SpringApplication.java:1363)
в org.springframework.boot.SpringApplication.run(SpringApplication.java:1352)
на com.aiyuns.tinkerplay.TinkerPlayApplication.main(TinkerPlayApplication.java:40)
на java.base/jdk.internal.reflect.DirectMethodHandleAccessor.invoke(DirectMethodHandleAccessor.java:103)
в java.base/java.lang.reflect.Method.invoke(Method.java:580)
в org.springframework.boot.loader.launch.Launcher.launch(Launcher.java:91)
в org.springframework.boot.loader.launch.Launcher.launch(Launcher.java:53)
в org.springframework.boot.loader.launch.JarLauncher.main(JarLauncher.java:58)
Вызвано: org.apache.flink.util.FlinkException: не удалось выполнить задание «mysql-cdc».
в org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.executeAsync(StreamExecutionEnvironment.java:2455).
в org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:2319)
в org.apache.flink.streaming.api.environment.LocalStreamEnvironment.execute(LocalStreamEnvironment. java:68)
на org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:2293)
на com.aiyuns.tinkerplay.Listener.MysqlEventListener.run(MysqlEventListener. java:77)
в org.springframework.boot.SpringApplication.lambda$callRunner$4(SpringApplication.java:786)
в org.springframework.util.function.ThrowingConsumer$1.acceptWithException(ThrowingConsumer.java: 83)
at org.springframework.util.function.ThrowingConsumer.accept(ThrowingConsumer.java:60)
... 22 общих кадра опущены
Вызвано: java.lang.RuntimeException: org .apache.flink.runtime.client.JobInitializationException: не удалось запустить JobMaster.
в org.apache.flink.util.ExceptionUtils.rethrow(ExceptionUtils.java:321)
в 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)
в java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:387)
at java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1312)
at java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1843)at java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1808)
at java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:188)Причина: org.apache.flink.runtime.client.JobInitializationException: не удалось запустить JobMaster.
в org.apache.flink.runtime.jobmaster.DefaultJobMasterServiceProcess.lambda$new$0(DefaultJobMasterServiceProcess.java: 97)
в java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:863)
в java.base/java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture. java:841)
в java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:510)
в java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run( CompletableFuture.java:1773)
в java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
в java.base/java.util.concurrent.ThreadPoolExecutor$Worker. run(ThreadPoolExecutor.java:642)
в java.base/java.lang.Thread.run(Thread.java:1583)
Вызвано: java.util.concurrent.CompletionException: java.lang. RuntimeException: java.lang.ClassNotFoundException: org.apache.flink.api.common.ExecutionConfig
at java.base/java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:315)
at java .base/java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:320)
в java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1770)
... 3 общих фрейма пропущены
Причина: java.lang.RuntimeException: java.lang.ClassNotFoundException: org.apache.flink.api.common.ExecutionConfig
at org.apache.flink.util. ExceptionUtils.rethrow(ExceptionUtils.java:321)
в org.apache.flink.util.function.FunctionUtils.lambda$uncheckedSupplier$4(FunctionUtils.java:114)
в java.base/java.util .concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1768)
... 3 общих фрейма пропущены
Причина: java.lang.ClassNotFoundException: org.apache.flink.api.common.ExecutionConfig
в java.base/jdk.internal.loader.BuiltinClassLoader.loadClass(BuiltinClassLoader.java:641)
в java.base/jdk.internal.loader.ClassLoaders$AppClassLoader.loadClass(ClassLoaders.java: 188)
в java.base/java.lang.ClassLoader.loadClass(ClassLoader.java:526)
в java.base/java.lang.Class.forName0(собственный метод)
at java.base/java.lang.Class.forName(Class.java:534)
в java.base/java.lang.Class.forName(Class.java:513)
в org.apache. flink.util.InstantiationUtil$ClassLoaderObjectInputStream.resolveClass(InstantiationUtil.java:78)
в java.base/java.io.ObjectInputStream.readNonProxyDesc(ObjectInputStream.java:2061)
в java.base/java. io.ObjectInputStream.readClassDesc(ObjectInputStream.java:1927)
в java.base/java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2252)
в java.base/java.io.ObjectInputStream. readObject0(ObjectInputStream.java:1762)
в java.base/java.io.ObjectInputStream.readObject(ObjectInputStream.java:540)
в java.base/java.io.ObjectInputStream.readObject(ObjectInputStream. java:498)
в org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:539)
в org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:527)
в org.apache.flink.util.SerializedValue.deserializeValue(SerializedValue.java:67)
в org.apache.flink.runtime.scheduler.DefaultSchedulerFactory.createInstance(DefaultSchedulerFactory.java:102)
в org.apache.flink.runtime.jobmaster.DefaultSlotPoolServiceSchedulerFactory.createScheduler(DefaultSlotPoolServiceSchedulerFactory.java:121)
в org.apache.flink.runtime.jobmaster.JobMaster.createScheduler(JobMaster.java:379)
в org.apache.flink.runtime.jobmaster.JobMaster.(JobMaster.java:356)
в 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 общих фрейма опущены
2024-05-29 10:02:19,751 ИНФОРМАЦИЯ (BlobServer.java:397) — остановлен BLOB-сервер по адресу 0.0.0.0:64666
2024-05-29 10:02:19,753 ИНФОРМАЦИЯ (PekkoRpcService.java:435) — остановлена ​​служба Pekko RPC.
=========== =============================================== =======
введите здесь описание изображения
введите здесь описание изображения
Пусть мой проект запустится нормально! Спасибо!

Подробнее здесь: https://stackoverflow.com/questions/785 ... ates-flink