Hi,米奇。 你可能需要添加 flink-core 的依赖或者将依赖的范围从 provided 改为 compile。 https://mvnrepository.com/artifact/org.apache.flink/flink-core/1.18.1
从 1.14 开始，Connector jar 已经不包含 flink-core 的内容了。 https://nightlies.apache.org/flink/flink-docs-release-1.18/release-notes/flink-1.14/#connector-base-exposes-dependency-to-flink-core Best， Yanquan 米奇 <1024557...@qq.com.invalid> 于 2025年1月26日周日 下午4:11写道： > 你好，现在遇到一个问题，本地springboot+flink > sql实现的一个垮库的联表查询，本地是可以用的，但是通过docker打成镜像后启动，访问接口会报如下错误，使用的是flink-1.18.1 > 2025-01-26 15:54:12 org.apache.flink.table.api.TableException: Failed > to execute sql > 2025-01-26 15:54:12 at > org.apache.flink.table.api.internal.TableEnvironmentImpl.executeQueryOperation(TableEnvironmentImpl.java:1084) > 2025-01-26 15:54:12 at > org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:1120) > 2025-01-26 15:54:12 at > org.apache.flink.table.api.internal.TableEnvironmentImpl.executeSql(TableEnvironmentImpl.java:735) > 2025-01-26 15:54:12 at > com.business.wms.report.service.impl.StockInfoServiceImpl.pageStockInfoByGoodsOrBasLot(StockInfoServiceImpl.java:533) > 2025-01-26 15:54:12 at > com.business.wms.report.controller.StockInfoByGoodsController.testFlink(StockInfoByGoodsController.java:125) > 2025-01-26 15:54:12 > at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) > 2025-01-26 15:54:12 > at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) > 2025-01-26 15:54:12 > at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) > 2025-01-26 15:54:12 > at java.base/java.lang.reflect.Method.invoke(Unknown Source) > 2025-01-26 15:54:12 at > org.springframework.web.method.support.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:205) > 2025-01-26 15:54:12 at > org.springframework.web.method.support.InvocableHandlerMethod.invokeForRequest(InvocableHandlerMethod.java:150) > 2025-01-26 15:54:12 at > org.springframework.web.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java:118) > 2025-01-26 15:54:12 at > org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandlerMethod(RequestMappingHandlerAdapter.java:884) > 2025-01-26 15:54:12 at > org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal(RequestMappingHandlerAdapter.java:797) > 2025-01-26 15:54:12 at > org.springframework.web.servlet.mvc.method.AbstractHandlerMethodAdapter.handle(AbstractHandlerMethodAdapter.java:87) > 2025-01-26 15:54:12 at > org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:1081) > 2025-01-26 15:54:12 at > org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:974) > 2025-01-26 15:54:12 at > org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:1014) > 2025-01-26 15:54:12 at > org.springframework.web.servlet.FrameworkServlet.doPost(FrameworkServlet.java:914) > 2025-01-26 15:54:12 at > jakarta.servlet.http.HttpServlet.service(HttpServlet.java:547) > 2025-01-26 15:54:12 at > org.springframework.web.servlet.FrameworkServlet.service(FrameworkServlet.java:885) > 2025-01-26 15:54:12 at > jakarta.servlet.http.HttpServlet.service(HttpServlet.java:614) > 2025-01-26 15:54:12 at > org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:205) > 2025-01-26 15:54:12 at > org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:149) > 2025-01-26 15:54:12 at > org.springframework.web.filter.CompositeFilter$VirtualFilterChain.doFilter(CompositeFilter.java:108) > 2025-01-26 15:54:12 at > org.springframework.security.web.FilterChainProxy.lambda$doFilterInternal$3(FilterChainProxy.java:231) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$FilterObservation$SimpleFilterObservation.lambda$wrap$1(ObservationFilterChainDecorator.java:479) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$AroundFilterObservation$SimpleAroundFilterObservation.lambda$wrap$1(ObservationFilterChainDecorator.java:340) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator.lambda$wrapSecured$0(ObservationFilterChainDecorator.java:82) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$VirtualFilterChain.doFilter(ObservationFilterChainDecorator.java:128) > 2025-01-26 15:54:12 at > org.springframework.security.web.access.intercept.AuthorizationFilter.doFilter(AuthorizationFilter.java:100) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$ObservationFilter.wrapFilter(ObservationFilterChainDecorator.java:240) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$ObservationFilter.doFilter(ObservationFilterChainDecorator.java:227) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$VirtualFilterChain.doFilter(ObservationFilterChainDecorator.java:137) > 2025-01-26 15:54:12 at > org.springframework.security.web.access.ExceptionTranslationFilter.doFilter(ExceptionTranslationFilter.java:126) > 2025-01-26 15:54:12 at > org.springframework.security.web.access.ExceptionTranslationFilter.doFilter(ExceptionTranslationFilter.java:120) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$ObservationFilter.wrapFilter(ObservationFilterChainDecorator.java:240) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$ObservationFilter.doFilter(ObservationFilterChainDecorator.java:227) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$VirtualFilterChain.doFilter(ObservationFilterChainDecorator.java:137) > 2025-01-26 15:54:12 at > org.springframework.security.web.session.SessionManagementFilter.doFilter(SessionManagementFilter.java:131) > 2025-01-26 15:54:12 at > org.springframework.security.web.session.SessionManagementFilter.doFilter(SessionManagementFilter.java:85) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$ObservationFilter.wrapFilter(ObservationFilterChainDecorator.java:240) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$ObservationFilter.doFilter(ObservationFilterChainDecorator.java:227) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$VirtualFilterChain.doFilter(ObservationFilterChainDecorator.java:137) > 2025-01-26 15:54:12 at > org.springframework.security.web.authentication.AnonymousAuthenticationFilter.doFilter(AnonymousAuthenticationFilter.java:100) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$ObservationFilter.wrapFilter(ObservationFilterChainDecorator.java:240) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$ObservationFilter.doFilter(ObservationFilterChainDecorator.java:227) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$VirtualFilterChain.doFilter(ObservationFilterChainDecorator.java:137) > 2025-01-26 15:54:12 at > org.springframework.security.web.servletapi.SecurityContextHolderAwareRequestFilter.doFilter(SecurityContextHolderAwareRequestFilter.java:179) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$ObservationFilter.wrapFilter(ObservationFilterChainDecorator.java:240) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$ObservationFilter.doFilter(ObservationFilterChainDecorator.java:227) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$VirtualFilterChain.doFilter(ObservationFilterChainDecorator.java:137) > 2025-01-26 15:54:12 at > org.springframework.security.oauth2.server.resource.web.authentication.BearerTokenAuthenticationFilter.doFilterInternal(BearerTokenAuthenticationFilter.java:145) > 2025-01-26 15:54:12 at > org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:116) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$ObservationFilter.wrapFilter(ObservationFilterChainDecorator.java:240) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$ObservationFilter.doFilter(ObservationFilterChainDecorator.java:227) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$VirtualFilterChain.doFilter(ObservationFilterChainDecorator.java:137) > 2025-01-26 15:54:12 at > org.springframework.security.web.authentication.logout.LogoutFilter.doFilter(LogoutFilter.java:107) > 2025-01-26 15:54:12 at > org.springframework.security.web.authentication.logout.LogoutFilter.doFilter(LogoutFilter.java:93) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$ObservationFilter.wrapFilter(ObservationFilterChainDecorator.java:240) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$ObservationFilter.doFilter(ObservationFilterChainDecorator.java:227) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$VirtualFilterChain.doFilter(ObservationFilterChainDecorator.java:137) > 2025-01-26 15:54:12 at > org.springframework.security.web.header.HeaderWriterFilter.doHeadersAfter(HeaderWriterFilter.java:90) > 2025-01-26 15:54:12 at > org.springframework.security.web.header.HeaderWriterFilter.doFilterInternal(HeaderWriterFilter.java:75) > 2025-01-26 15:54:12 at > org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:116) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$ObservationFilter.wrapFilter(ObservationFilterChainDecorator.java:240) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$ObservationFilter.doFilter(ObservationFilterChainDecorator.java:227) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$VirtualFilterChain.doFilter(ObservationFilterChainDecorator.java:137) > 2025-01-26 15:54:12 at > org.springframework.security.web.context.SecurityContextHolderFilter.doFilter(SecurityContextHolderFilter.java:82) > 2025-01-26 15:54:12 at > org.springframework.security.web.context.SecurityContextHolderFilter.doFilter(SecurityContextHolderFilter.java:69) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$ObservationFilter.wrapFilter(ObservationFilterChainDecorator.java:240) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$ObservationFilter.doFilter(ObservationFilterChainDecorator.java:227) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$VirtualFilterChain.doFilter(ObservationFilterChainDecorator.java:137) > 2025-01-26 15:54:12 at > org.springframework.security.web.context.request.async.WebAsyncManagerIntegrationFilter.doFilterInternal(WebAsyncManagerIntegrationFilter.java:62) > 2025-01-26 15:54:12 at > org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:116) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$ObservationFilter.wrapFilter(ObservationFilterChainDecorator.java:240) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$ObservationFilter.doFilter(ObservationFilterChainDecorator.java:227) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$VirtualFilterChain.doFilter(ObservationFilterChainDecorator.java:137) > 2025-01-26 15:54:12 at > org.springframework.security.web.session.DisableEncodeUrlFilter.doFilterInternal(DisableEncodeUrlFilter.java:42) > 2025-01-26 15:54:12 at > org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:116) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$ObservationFilter.wrapFilter(ObservationFilterChainDecorator.java:240) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$AroundFilterObservation$SimpleAroundFilterObservation.lambda$wrap$0(ObservationFilterChainDecorator.java:323) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$ObservationFilter.doFilter(ObservationFilterChainDecorator.java:224) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$VirtualFilterChain.doFilter(ObservationFilterChainDecorator.java:137) > 2025-01-26 15:54:12 at > org.springframework.security.web.FilterChainProxy.doFilterInternal(FilterChainProxy.java:233) > 2025-01-26 15:54:12 at > org.springframework.security.web.FilterChainProxy.doFilter(FilterChainProxy.java:191) > 2025-01-26 15:54:12 at > org.springframework.web.filter.CompositeFilter$VirtualFilterChain.doFilter(CompositeFilter.java:113) > 2025-01-26 15:54:12 at > org.springframework.web.servlet.handler.HandlerMappingIntrospector.lambda$createCacheFilter$3(HandlerMappingIntrospector.java:195) > 2025-01-26 15:54:12 at > org.springframework.web.filter.CompositeFilter$VirtualFilterChain.doFilter(CompositeFilter.java:113) > 2025-01-26 15:54:12 at > org.springframework.web.filter.CompositeFilter.doFilter(CompositeFilter.java:74) > 2025-01-26 15:54:12 at > org.springframework.security.config.annotation.web.configuration.WebMvcSecurityConfiguration$CompositeFilterChainProxy.doFilter(WebMvcSecurityConfiguration.java:225) > 2025-01-26 15:54:12 at > org.springframework.web.filter.DelegatingFilterProxy.invokeDelegate(DelegatingFilterProxy.java:352) > 2025-01-26 15:54:12 at > org.springframework.web.filter.DelegatingFilterProxy.doFilter(DelegatingFilterProxy.java:268) > 2025-01-26 15:54:12 at > org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:174) > 2025-01-26 15:54:12 at > org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:149) > 2025-01-26 15:54:12 at > org.springframework.web.filter.RequestContextFilter.doFilterInternal(RequestContextFilter.java:100) > 2025-01-26 15:54:12 at > org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:116) > 2025-01-26 15:54:12 at > org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:174) > 2025-01-26 15:54:12 at > org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:149) > 2025-01-26 15:54:12 at > org.springframework.web.filter.FormContentFilter.doFilterInternal(FormContentFilter.java:93) > 2025-01-26 15:54:12 at > org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:116) > 2025-01-26 15:54:12 at > org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:174) > 2025-01-26 15:54:12 at > org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:149) > 2025-01-26 15:54:12 at > org.springframework.web.filter.ServerHttpObservationFilter.doFilterInternal(ServerHttpObservationFilter.java:109) > 2025-01-26 15:54:12 at > org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:116) > 2025-01-26 15:54:12 at > org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:174) > 2025-01-26 15:54:12 at > org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:149) > 2025-01-26 15:54:12 at > org.springframework.web.filter.CharacterEncodingFilter.doFilterInternal(CharacterEncodingFilter.java:201) > 2025-01-26 15:54:12 at > org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:116) > 2025-01-26 15:54:12 at > org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:174) > 2025-01-26 15:54:12 at > org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:149) > 2025-01-26 15:54:12 at > org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:167) > 2025-01-26 15:54:12 at > org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:90) > 2025-01-26 15:54:12 at > org.apache.catalina.authenticator.AuthenticatorBase.invoke(AuthenticatorBase.java:482) > 2025-01-26 15:54:12 at > org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:115) > 2025-01-26 15:54:12 at > org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:93) > 2025-01-26 15:54:12 at > org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:74) > 2025-01-26 15:54:12 at > org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:340) > 2025-01-26 15:54:12 at > org.apache.coyote.http11.Http11Processor.service(Http11Processor.java:391) > 2025-01-26 15:54:12 at > org.apache.coyote.AbstractProcessorLight.process(AbstractProcessorLight.java:63) > 2025-01-26 15:54:12 at > org.apache.coyote.AbstractProtocol$ConnectionHandler.process(AbstractProtocol.java:896) > 2025-01-26 15:54:12 at > org.apache.tomcat.util.net > .NioEndpoint$SocketProcessor.doRun(NioEndpoint.java:1744) > 2025-01-26 15:54:12 at > org.apache.tomcat.util.net > .SocketProcessorBase.run(SocketProcessorBase.java:52) > 2025-01-26 15:54:12 at > org.apache.tomcat.util.threads.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1191) > 2025-01-26 15:54:12 at > org.apache.tomcat.util.threads.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:659) > 2025-01-26 15:54:12 at > org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61) > 2025-01-26 15:54:12 > at java.base/java.lang.Thread.run(Unknown Source) > 2025-01-26 15:54:12 Caused by: org.apache.flink.util.FlinkException: > Failed to execute job 'collect'. > 2025-01-26 15:54:12 at > org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.executeAsync(StreamExecutionEnvironment.java:2253) > 2025-01-26 15:54:12 at > org.apache.flink.table.planner.delegation.DefaultExecutor.executeAsync(DefaultExecutor.java:110) > 2025-01-26 15:54:12 at > org.apache.flink.table.api.internal.TableEnvironmentImpl.executeQueryOperation(TableEnvironmentImpl.java:1065) > 2025-01-26 15:54:12 ... 126 more > 2025-01-26 15:54:12 Caused by: java.lang.RuntimeException: > org.apache.flink.runtime.client.JobInitializationException: Could not start > the JobMaster. > 2025-01-26 15:54:12 at > org.apache.flink.util.ExceptionUtils.rethrow(ExceptionUtils.java:321) > 2025-01-26 15:54:12 at > org.apache.flink.util.function.FunctionUtils.lambda$uncheckedFunction$2(FunctionUtils.java:75) > 2025-01-26 15:54:12 > at java.base/java.util.concurrent.CompletableFuture$UniApply.tryFire(Unknown Source) > 2025-01-26 15:54:12 > at java.base/java.util.concurrent.CompletableFuture$Completion.exec(Unknown Source) > 2025-01-26 15:54:12 > at java.base/java.util.concurrent.ForkJoinTask.doExec(Unknown Source) > 2025-01-26 15:54:12 > at java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(Unknown Source) > 2025-01-26 15:54:12 > at java.base/java.util.concurrent.ForkJoinPool.scan(Unknown Source) > 2025-01-26 15:54:12 > at java.base/java.util.concurrent.ForkJoinPool.runWorker(Unknown Source) > 2025-01-26 15:54:12 > at java.base/java.util.concurrent.ForkJoinWorkerThread.run(Unknown Source) > 2025-01-26 15:54:12 Caused by: > org.apache.flink.runtime.client.JobInitializationException: Could not start > the JobMaster. > 2025-01-26 15:54:12 at > org.apache.flink.runtime.jobmaster.DefaultJobMasterServiceProcess.lambda$new$0(DefaultJobMasterServiceProcess.java:97) > 2025-01-26 15:54:12 > at java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(Unknown Source) > 2025-01-26 15:54:12 > at java.base/java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(Unknown Source) > 2025-01-26 15:54:12 > at java.base/java.util.concurrent.CompletableFuture.postComplete(Unknown Source) > 2025-01-26 15:54:12 > at java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(Unknown Source) > 2025-01-26 15:54:12 > at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) > 2025-01-26 15:54:12 > at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) > 2025-01-26 15:54:12 > at java.base/java.lang.Thread.run(Unknown Source) > 2025-01-26 15:54:12 Caused by: > java.util.concurrent.CompletionException: java.lang.RuntimeException: > java.lang.ClassNotFoundException: > org.apache.flink.api.common.ExecutionConfig > 2025-01-26 15:54:12 > at java.base/java.util.concurrent.CompletableFuture.encodeThrowable(Unknown Source) > 2025-01-26 15:54:12 > at java.base/java.util.concurrent.CompletableFuture.completeThrowable(Unknown Source) > 2025-01-26 15:54:12 ... 4 more > 2025-01-26 15:54:12 Caused by: java.lang.RuntimeException: > java.lang.ClassNotFoundException: > org.apache.flink.api.common.ExecutionConfig > 2025-01-26 15:54:12 at > org.apache.flink.util.ExceptionUtils.rethrow(ExceptionUtils.java:321) > 2025-01-26 15:54:12 at > org.apache.flink.util.function.FunctionUtils.lambda$uncheckedSupplier$4(FunctionUtils.java:114) > 2025-01-26 15:54:12 ... 4 more > 2025-01-26 15:54:12 Caused by: java.lang.ClassNotFoundException: > org.apache.flink.api.common.ExecutionConfig > 2025-01-26 15:54:12 > at java.base/jdk.internal.loader.BuiltinClassLoader.loadClass(Unknown Source) > 2025-01-26 15:54:12 > at java.base/jdk.internal.loader.ClassLoaders$AppClassLoader.loadClass(Unknown Source) > 2025-01-26 15:54:12 > at java.base/java.lang.ClassLoader.loadClass(Unknown Source) > 2025-01-26 15:54:12 > at java.base/java.lang.Class.forName0(Native Method) > 2025-01-26 15:54:12 > at java.base/java.lang.Class.forName(Unknown Source) > 2025-01-26 15:54:12 at > org.apache.flink.util.InstantiationUtil$ClassLoaderObjectInputStream.resolveClass(InstantiationUtil.java:78) > 2025-01-26 15:54:12 at java.base/java.io > .ObjectInputStream.readNonProxyDesc(Unknown Source) > 2025-01-26 15:54:12 at java.base/java.io > .ObjectInputStream.readClassDesc(Unknown Source) > 2025-01-26 15:54:12 at java.base/java.io > .ObjectInputStream.readOrdinaryObject(Unknown Source) > 2025-01-26 15:54:12 at java.base/java.io > .ObjectInputStream.readObject0(Unknown Source) > 2025-01-26 15:54:12 at java.base/java.io > .ObjectInputStream.readObject(Unknown Source) > 2025-01-26 15:54:12 at java.base/java.io > .ObjectInputStream.readObject(Unknown Source) > 2025-01-26 15:54:12 at > org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:539) > 2025-01-26 15:54:12 at > org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:527) > 2025-01-26 15:54:12 at > org.apache.flink.util.SerializedValue.deserializeValue(SerializedValue.java:67) > 2025-01-26 15:54:12 at > org.apache.flink.runtime.scheduler.DefaultSchedulerFactory.createInstance(DefaultSchedulerFactory.java:101) > 2025-01-26 15:54:12 at > org.apache.flink.runtime.jobmaster.DefaultSlotPoolServiceSchedulerFactory.createScheduler(DefaultSlotPoolServiceSchedulerFactory.java:122) > 2025-01-26 15:54:12 at > org.apache.flink.runtime.jobmaster.JobMaster.createScheduler(JobMaster.java:379) > 2025-01-26 15:54:12 at > org.apache.flink.runtime.jobmaster.JobMaster.<init>(JobMaster.java:356) > 2025-01-26 15:54:12 at > org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.internalCreateJobMasterService(DefaultJobMasterServiceFactory.java:128) > 2025-01-26 15:54:12 at > org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.lambda$createJobMasterService$0(DefaultJobMasterServiceFactory.java:100) > 2025-01-26 15:54:12 at > org.apache.flink.util.function.FunctionUtils.lambda$uncheckedSupplier$4(FunctionUtils.java:112) > 2025-01-26 15:54:12 ... 4 more > 2025-01-26 15:54:12 MyLogPattern 2025-01-26 15:54:12.716 > ERROR 1 --- [nio-9108-exec-1] > c.l.c.c.c.a.GlobalExceptionHandler : > unknown exception > 2025-01-26 15:54:12 > 2025-01-26 15:54:12 org.apache.flink.table.api.TableException: Failed > to execute sql > 2025-01-26 15:54:12 at > org.apache.flink.table.api.internal.TableEnvironmentImpl.executeQueryOperation(TableEnvironmentImpl.java:1084) > 2025-01-26 15:54:12 at > org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:1120) > 2025-01-26 15:54:12 at > org.apache.flink.table.api.internal.TableEnvironmentImpl.executeSql(TableEnvironmentImpl.java:735) > 2025-01-26 15:54:12 at > com.business.wms.report.service.impl.StockInfoServiceImpl.pageStockInfoByGoodsOrBasLot(StockInfoServiceImpl.java:533) > 2025-01-26 15:54:12 at > com.business.wms.report.controller.StockInfoByGoodsController.testFlink(StockInfoByGoodsController.java:125) > 2025-01-26 15:54:12 > at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) > 2025-01-26 15:54:12 > at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) > 2025-01-26 15:54:12 > at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) > 2025-01-26 15:54:12 > at java.base/java.lang.reflect.Method.invoke(Unknown Source) > 2025-01-26 15:54:12 at > org.springframework.web.method.support.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:205) > 2025-01-26 15:54:12 at > org.springframework.web.method.support.InvocableHandlerMethod.invokeForRequest(InvocableHandlerMethod.java:150) > 2025-01-26 15:54:12 at > org.springframework.web.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java:118) > 2025-01-26 15:54:12 at > org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandlerMethod(RequestMappingHandlerAdapter.java:884) > 2025-01-26 15:54:12 at > org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal(RequestMappingHandlerAdapter.java:797) > 2025-01-26 15:54:12 at > org.springframework.web.servlet.mvc.method.AbstractHandlerMethodAdapter.handle(AbstractHandlerMethodAdapter.java:87) > 2025-01-26 15:54:12 at > org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:1081) > 2025-01-26 15:54:12 at > org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:974) > 2025-01-26 15:54:12 at > org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:1014) > 2025-01-26 15:54:12 at > org.springframework.web.servlet.FrameworkServlet.doPost(FrameworkServlet.java:914) > 2025-01-26 15:54:12 at > jakarta.servlet.http.HttpServlet.service(HttpServlet.java:547) > 2025-01-26 15:54:12 at > org.springframework.web.servlet.FrameworkServlet.service(FrameworkServlet.java:885) > 2025-01-26 15:54:12 at > jakarta.servlet.http.HttpServlet.service(HttpServlet.java:614) > 2025-01-26 15:54:12 at > org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:205) > 2025-01-26 15:54:12 at > org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:149) > 2025-01-26 15:54:12 at > org.springframework.web.filter.CompositeFilter$VirtualFilterChain.doFilter(CompositeFilter.java:108) > 2025-01-26 15:54:12 at > org.springframework.security.web.FilterChainProxy.lambda$doFilterInternal$3(FilterChainProxy.java:231) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$FilterObservation$SimpleFilterObservation.lambda$wrap$1(ObservationFilterChainDecorator.java:479) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$AroundFilterObservation$SimpleAroundFilterObservation.lambda$wrap$1(ObservationFilterChainDecorator.java:340) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator.lambda$wrapSecured$0(ObservationFilterChainDecorator.java:82) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$VirtualFilterChain.doFilter(ObservationFilterChainDecorator.java:128) > 2025-01-26 15:54:12 at > org.springframework.security.web.access.intercept.AuthorizationFilter.doFilter(AuthorizationFilter.java:100) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$ObservationFilter.wrapFilter(ObservationFilterChainDecorator.java:240) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$ObservationFilter.doFilter(ObservationFilterChainDecorator.java:227) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$VirtualFilterChain.doFilter(ObservationFilterChainDecorator.java:137) > 2025-01-26 15:54:12 at > org.springframework.security.web.access.ExceptionTranslationFilter.doFilter(ExceptionTranslationFilter.java:126) > 2025-01-26 15:54:12 at > org.springframework.security.web.access.ExceptionTranslationFilter.doFilter(ExceptionTranslationFilter.java:120) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$ObservationFilter.wrapFilter(ObservationFilterChainDecorator.java:240) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$ObservationFilter.doFilter(ObservationFilterChainDecorator.java:227) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$VirtualFilterChain.doFilter(ObservationFilterChainDecorator.java:137) > 2025-01-26 15:54:12 at > org.springframework.security.web.session.SessionManagementFilter.doFilter(SessionManagementFilter.java:131) > 2025-01-26 15:54:12 at > org.springframework.security.web.session.SessionManagementFilter.doFilter(SessionManagementFilter.java:85) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$ObservationFilter.wrapFilter(ObservationFilterChainDecorator.java:240) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$ObservationFilter.doFilter(ObservationFilterChainDecorator.java:227) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$VirtualFilterChain.doFilter(ObservationFilterChainDecorator.java:137) > 2025-01-26 15:54:12 at > org.springframework.security.web.authentication.AnonymousAuthenticationFilter.doFilter(AnonymousAuthenticationFilter.java:100) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$ObservationFilter.wrapFilter(ObservationFilterChainDecorator.java:240) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$ObservationFilter.doFilter(ObservationFilterChainDecorator.java:227) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$VirtualFilterChain.doFilter(ObservationFilterChainDecorator.java:137) > 2025-01-26 15:54:12 at > org.springframework.security.web.servletapi.SecurityContextHolderAwareRequestFilter.doFilter(SecurityContextHolderAwareRequestFilter.java:179) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$ObservationFilter.wrapFilter(ObservationFilterChainDecorator.java:240) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$ObservationFilter.doFilter(ObservationFilterChainDecorator.java:227) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$VirtualFilterChain.doFilter(ObservationFilterChainDecorator.java:137) > 2025-01-26 15:54:12 at > org.springframework.security.oauth2.server.resource.web.authentication.BearerTokenAuthenticationFilter.doFilterInternal(BearerTokenAuthenticationFilter.java:145) > 2025-01-26 15:54:12 at > org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:116) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$ObservationFilter.wrapFilter(ObservationFilterChainDecorator.java:240) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$ObservationFilter.doFilter(ObservationFilterChainDecorator.java:227) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$VirtualFilterChain.doFilter(ObservationFilterChainDecorator.java:137) > 2025-01-26 15:54:12 at > org.springframework.security.web.authentication.logout.LogoutFilter.doFilter(LogoutFilter.java:107) > 2025-01-26 15:54:12 at > org.springframework.security.web.authentication.logout.LogoutFilter.doFilter(LogoutFilter.java:93) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$ObservationFilter.wrapFilter(ObservationFilterChainDecorator.java:240) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$ObservationFilter.doFilter(ObservationFilterChainDecorator.java:227) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$VirtualFilterChain.doFilter(ObservationFilterChainDecorator.java:137) > 2025-01-26 15:54:12 at > org.springframework.security.web.header.HeaderWriterFilter.doHeadersAfter(HeaderWriterFilter.java:90) > 2025-01-26 15:54:12 at > org.springframework.security.web.header.HeaderWriterFilter.doFilterInternal(HeaderWriterFilter.java:75) > 2025-01-26 15:54:12 at > org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:116) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$ObservationFilter.wrapFilter(ObservationFilterChainDecorator.java:240) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$ObservationFilter.doFilter(ObservationFilterChainDecorator.java:227) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$VirtualFilterChain.doFilter(ObservationFilterChainDecorator.java:137) > 2025-01-26 15:54:12 at > org.springframework.security.web.context.SecurityContextHolderFilter.doFilter(SecurityContextHolderFilter.java:82) > 2025-01-26 15:54:12 at > org.springframework.security.web.context.SecurityContextHolderFilter.doFilter(SecurityContextHolderFilter.java:69) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$ObservationFilter.wrapFilter(ObservationFilterChainDecorator.java:240) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$ObservationFilter.doFilter(ObservationFilterChainDecorator.java:227) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$VirtualFilterChain.doFilter(ObservationFilterChainDecorator.java:137) > 2025-01-26 15:54:12 at > org.springframework.security.web.context.request.async.WebAsyncManagerIntegrationFilter.doFilterInternal(WebAsyncManagerIntegrationFilter.java:62) > 2025-01-26 15:54:12 at > org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:116) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$ObservationFilter.wrapFilter(ObservationFilterChainDecorator.java:240) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$ObservationFilter.doFilter(ObservationFilterChainDecorator.java:227) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$VirtualFilterChain.doFilter(ObservationFilterChainDecorator.java:137) > 2025-01-26 15:54:12 at > org.springframework.security.web.session.DisableEncodeUrlFilter.doFilterInternal(DisableEncodeUrlFilter.java:42) > 2025-01-26 15:54:12 at > org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:116) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$ObservationFilter.wrapFilter(ObservationFilterChainDecorator.java:240) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$AroundFilterObservation$SimpleAroundFilterObservation.lambda$wrap$0(ObservationFilterChainDecorator.java:323) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$ObservationFilter.doFilter(ObservationFilterChainDecorator.java:224) > 2025-01-26 15:54:12 at > org.springframework.security.web.ObservationFilterChainDecorator$VirtualFilterChain.doFilter(ObservationFilterChainDecorator.java:137) > 2025-01-26 15:54:12 at > org.springframework.security.web.FilterChainProxy.doFilterInternal(FilterChainProxy.java:233) > 2025-01-26 15:54:12 at > org.springframework.security.web.FilterChainProxy.doFilter(FilterChainProxy.java:191) > 2025-01-26 15:54:12 at > org.springframework.web.filter.CompositeFilter$VirtualFilterChain.doFilter(CompositeFilter.java:113) > 2025-01-26 15:54:12 at > org.springframework.web.servlet.handler.HandlerMappingIntrospector.lambda$createCacheFilter$3(HandlerMappingIntrospector.java:195) > 2025-01-26 15:54:12 at > org.springframework.web.filter.CompositeFilter$VirtualFilterChain.doFilter(CompositeFilter.java:113) > 2025-01-26 15:54:12 at > org.springframework.web.filter.CompositeFilter.doFilter(CompositeFilter.java:74) > 2025-01-26 15:54:12 at > org.springframework.security.config.annotation.web.configuration.WebMvcSecurityConfiguration$CompositeFilterChainProxy.doFilter(WebMvcSecurityConfiguration.java:225) > 2025-01-26 15:54:12 at > org.springframework.web.filter.DelegatingFilterProxy.invokeDelegate(DelegatingFilterProxy.java:352) > 2025-01-26 15:54:12 at > org.springframework.web.filter.DelegatingFilterProxy.doFilter(DelegatingFilterProxy.java:268) > 2025-01-26 15:54:12 at > org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:174) > 2025-01-26 15:54:12 at > org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:149) > 2025-01-26 15:54:12 at > org.springframework.web.filter.RequestContextFilter.doFilterInternal(RequestContextFilter.java:100) > 2025-01-26 15:54:12 at > org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:116) > 2025-01-26 15:54:12 at > org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:174) > 2025-01-26 15:54:12 at > org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:149) > 2025-01-26 15:54:12 at > org.springframework.web.filter.FormContentFilter.doFilterInternal(FormContentFilter.java:93) > 2025-01-26 15:54:12 at > org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:116) > 2025-01-26 15:54:12 at > org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:174) > 2025-01-26 15:54:12 at > org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:149) > 2025-01-26 15:54:12 at > org.springframework.web.filter.ServerHttpObservationFilter.doFilterInternal(ServerHttpObservationFilter.java:109) > 2025-01-26 15:54:12 at > org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:116) > 2025-01-26 15:54:12 at > org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:174) > 2025-01-26 15:54:12 at > org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:149) > 2025-01-26 15:54:12 at > org.springframework.web.filter.CharacterEncodingFilter.doFilterInternal(CharacterEncodingFilter.java:201) > 2025-01-26 15:54:12 at > org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:116) > 2025-01-26 15:54:12 at > org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:174) > 2025-01-26 15:54:12 at > org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:149) > 2025-01-26 15:54:12 at > org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:167) > 2025-01-26 15:54:12 at > org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:90) > 2025-01-26 15:54:12 at > org.apache.catalina.authenticator.AuthenticatorBase.invoke(AuthenticatorBase.java:482) > 2025-01-26 15:54:12 at > org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:115) > 2025-01-26 15:54:12 at > org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:93) > 2025-01-26 15:54:12 at > org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:74) > 2025-01-26 15:54:12 at > org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:340) > 2025-01-26 15:54:12 at > org.apache.coyote.http11.Http11Processor.service(Http11Processor.java:391) > 2025-01-26 15:54:12 at > org.apache.coyote.AbstractProcessorLight.process(AbstractProcessorLight.java:63) > 2025-01-26 15:54:12 at > org.apache.coyote.AbstractProtocol$ConnectionHandler.process(AbstractProtocol.java:896) > 2025-01-26 15:54:12 at > org.apache.tomcat.util.net > .NioEndpoint$SocketProcessor.doRun(NioEndpoint.java:1744) > 2025-01-26 15:54:12 at > org.apache.tomcat.util.net > .SocketProcessorBase.run(SocketProcessorBase.java:52) > 2025-01-26 15:54:12 at > org.apache.tomcat.util.threads.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1191) > 2025-01-26 15:54:12 at > org.apache.tomcat.util.threads.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:659) > 2025-01-26 15:54:12 at > org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61) > 2025-01-26 15:54:12 > at java.base/java.lang.Thread.run(Unknown Source) > 2025-01-26 15:54:12 Caused by: org.apache.flink.util.FlinkException: > Failed to execute job 'collect'. > 2025-01-26 15:54:12 at > org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.executeAsync(StreamExecutionEnvironment.java:2253) > 2025-01-26 15:54:12 at > org.apache.flink.table.planner.delegation.DefaultExecutor.executeAsync(DefaultExecutor.java:110) > 2025-01-26 15:54:12 at > org.apache.flink.table.api.internal.TableEnvironmentImpl.executeQueryOperation(TableEnvironmentImpl.java:1065) > 2025-01-26 15:54:12 ... 126 common frames > omitted > 2025-01-26 15:54:12 Caused by: java.lang.RuntimeException: > org.apache.flink.runtime.client.JobInitializationException: Could not start > the JobMaster. > 2025-01-26 15:54:12 at > org.apache.flink.util.ExceptionUtils.rethrow(ExceptionUtils.java:321) > 2025-01-26 15:54:12 at > org.apache.flink.util.function.FunctionUtils.lambda$uncheckedFunction$2(FunctionUtils.java:75) > 2025-01-26 15:54:12 > at java.base/java.util.concurrent.CompletableFuture$UniApply.tryFire(Unknown Source) > 2025-01-26 15:54:12 > at java.base/java.util.concurrent.CompletableFuture$Completion.exec(Unknown Source) > 2025-01-26 15:54:12 > at java.base/java.util.concurrent.ForkJoinTask.doExec(Unknown Source) > 2025-01-26 15:54:12 > at java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(Unknown Source) > 2025-01-26 15:54:12 > at java.base/java.util.concurrent.ForkJoinPool.scan(Unknown Source) > 2025-01-26 15:54:12 > at java.base/java.util.concurrent.ForkJoinPool.runWorker(Unknown Source) > 2025-01-26 15:54:12 > at java.base/java.util.concurrent.ForkJoinWorkerThread.run(Unknown Source) > 2025-01-26 15:54:12 Caused by: > org.apache.flink.runtime.client.JobInitializationException: Could not start > the JobMaster. > 2025-01-26 15:54:12 at > org.apache.flink.runtime.jobmaster.DefaultJobMasterServiceProcess.lambda$new$0(DefaultJobMasterServiceProcess.java:97) > 2025-01-26 15:54:12 > at java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(Unknown Source) > 2025-01-26 15:54:12 > at java.base/java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(Unknown Source) > 2025-01-26 15:54:12 > at java.base/java.util.concurrent.CompletableFuture.postComplete(Unknown Source) > 2025-01-26 15:54:12 > at java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(Unknown Source) > 2025-01-26 15:54:12 > at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) > 2025-01-26 15:54:12 > at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) > 2025-01-26 15:54:12 > at java.base/java.lang.Thread.run(Unknown Source) > 2025-01-26 15:54:12 Caused by: > java.util.concurrent.CompletionException: java.lang.RuntimeException: > java.lang.ClassNotFoundException: > org.apache.flink.api.common.ExecutionConfig > 2025-01-26 15:54:12 > at java.base/java.util.concurrent.CompletableFuture.encodeThrowable(Unknown Source) > 2025-01-26 15:54:12 > at java.base/java.util.concurrent.CompletableFuture.completeThrowable(Unknown Source) > 2025-01-26 15:54:12 ... 4 common frames > omitted > 2025-01-26 15:54:12 Caused by: java.lang.RuntimeException: > java.lang.ClassNotFoundException: > org.apache.flink.api.common.ExecutionConfig > 2025-01-26 15:54:12 at > org.apache.flink.util.ExceptionUtils.rethrow(ExceptionUtils.java:321) > 2025-01-26 15:54:12 at > org.apache.flink.util.function.FunctionUtils.lambda$uncheckedSupplier$4(FunctionUtils.java:114) > 2025-01-26 15:54:12 ... 4 common frames > omitted > 2025-01-26 15:54:12 Caused by: java.lang.ClassNotFoundException: > org.apache.flink.api.common.ExecutionConfig > 2025-01-26 15:54:12 > at java.base/jdk.internal.loader.BuiltinClassLoader.loadClass(Unknown Source) > 2025-01-26 15:54:12 > at java.base/jdk.internal.loader.ClassLoaders$AppClassLoader.loadClass(Unknown Source) > 2025-01-26 15:54:12 > at java.base/java.lang.ClassLoader.loadClass(Unknown Source) > 2025-01-26 15:54:12 > at java.base/java.lang.Class.forName0(Native Method) > 2025-01-26 15:54:12 > at java.base/java.lang.Class.forName(Unknown Source) > 2025-01-26 15:54:12 at > org.apache.flink.util.InstantiationUtil$ClassLoaderObjectInputStream.resolveClass(InstantiationUtil.java:78) > 2025-01-26 15:54:12 at java.base/java.io > .ObjectInputStream.readNonProxyDesc(Unknown Source) > 2025-01-26 15:54:12 at java.base/java.io > .ObjectInputStream.readClassDesc(Unknown Source) > 2025-01-26 15:54:12 at java.base/java.io > .ObjectInputStream.readOrdinaryObject(Unknown Source) > 2025-01-26 15:54:12 at java.base/java.io > .ObjectInputStream.readObject0(Unknown Source) > 2025-01-26 15:54:12 at java.base/java.io > .ObjectInputStream.readObject(Unknown Source) > 2025-01-26 15:54:12 at java.base/java.io > .ObjectInputStream.readObject(Unknown Source) > 2025-01-26 15:54:12 at > org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:539) > 2025-01-26 15:54:12 at > org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:527) > 2025-01-26 15:54:12 at > org.apache.flink.util.SerializedValue.deserializeValue(SerializedValue.java:67) > 2025-01-26 15:54:12 at > org.apache.flink.runtime.scheduler.DefaultSchedulerFactory.createInstance(DefaultSchedulerFactory.java:101) > 2025-01-26 15:54:12 at > org.apache.flink.runtime.jobmaster.DefaultSlotPoolServiceSchedulerFactory.createScheduler(DefaultSlotPoolServiceSchedulerFactory.java:122) > 2025-01-26 15:54:12 at > org.apache.flink.runtime.jobmaster.JobMaster.createScheduler(JobMaster.java:379) > 2025-01-26 15:54:12 at > org.apache.flink.runtime.jobmaster.JobMaster.<init>(JobMaster.java:356) > 2025-01-26 15:54:12 at > org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.internalCreateJobMasterService(DefaultJobMasterServiceFactory.java:128) > 2025-01-26 15:54:12 at > org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.lambda$createJobMasterService$0(DefaultJobMasterServiceFactory.java:100) > 2025-01-26 15:54:12 at > org.apache.flink.util.function.FunctionUtils.lambda$uncheckedSupplier$4(FunctionUtils.java:112) > 2025-01-26 15:54:12 ... 4 common frames > omitted > > > > 上一封 下一封 > « 返回 > > > > > > > > 米奇 > 1024557...@qq.com > > > >
