search

DataLinkDC / dinky

Dinky is a real-time data development platform based on Apache Flink, enabling agile data development, deployment and operation.
http://www.dinky.org.cn
Apache License 2.0
3.06k stars 1.13k forks source link

dolphinscheduler calls dinky tasks and concurrent execution exceptions #3400

Open pepperago opened 5 months ago

pepperago commented 5 months ago

Search before asking

What happened

通过海豚调度并发调用dinky任务，会出现部分任务直接失败，dinky上任务也没执行

What you expected to happen

[dinky] 2024-04-22 14:39:45 CST INFO  org.dinky.service.impl.TaskServiceImpl 562 initTenantByTaskId - Init task tenan finished..
[dinky] 2024-04-22 14:39:45 CST WARN  org.dinky.aop.ProcessAspect 94 processStepAround - Process null does not exist, This registration step SUBMIT_PRECHECK was abandoned
[dinky] 2024-04-22 14:39:45 CST INFO  org.dinky.service.impl.TaskServiceImpl 562 initTenantByTaskId - Init task tenan finished..
[dinky] 2024-04-22 14:39:45 CST WARN  org.dinky.aop.ProcessAspect 94 processStepAround - Process null does not exist, This registration step SUBMIT_PRECHECK was abandoned
[dinky] 2024-04-22 14:39:45 CST INFO  org.dinky.service.impl.TaskServiceImpl 562 initTenantByTaskId - Init task tenan finished..
[dinky] 2024-04-22 14:39:45 CST WARN  org.dinky.aop.ProcessAspect 94 processStepAround - Process null does not exist, This registration step SUBMIT_PRECHECK was abandoned
[dinky] 2024-04-22 14:39:45 CST INFO  org.dinky.service.impl.TaskServiceImpl 562 initTenantByTaskId - Init task tenan finished..
[dinky] 2024-04-22 14:39:45 CST WARN  org.dinky.aop.ProcessAspect 94 processStepAround - Process null does not exist, This registration step SUBMIT_PRECHECK was abandoned
[dinky] 2024-04-22 14:39:45 CST INFO  org.dinky.service.impl.TaskServiceImpl 177 prepareTask - Start check and config task, task:ods.news-flash-flash-news-template-data
[dinky] 2024-04-22 14:39:45 CST INFO  org.dinky.service.impl.TaskServiceImpl 177 prepareTask - Start check and config task, task:ods.news-flash-flash-news-template
[dinky] 2024-04-22 14:39:45 CST WARN  org.dinky.aop.ProcessAspect 94 processStepAround - Process null does not exist, This registration step SUBMIT_EXECUTE was abandoned
[dinky] 2024-04-22 14:39:45 CST WARN  org.dinky.aop.ProcessAspect 94 processStepAround - Process null does not exist, This registration step SUBMIT_EXECUTE was abandoned
[dinky] 2024-04-22 14:39:45 CST WARN  org.dinky.aop.ProcessAspect 94 processStepAround - Process null does not exist, This registration step SUBMIT_BUILD_CONFIG was abandoned
[dinky] 2024-04-22 14:39:45 CST INFO  org.dinky.service.impl.TaskServiceImpl 286 buildEnvSql - Start initialize FlinkSQLEnv:
[dinky] 2024-04-22 14:39:45 CST INFO  org.dinky.service.impl.TaskServiceImpl 177 prepareTask - Start check and config task, task:ods.article-cms-rl-template-article
[dinky] 2024-04-22 14:39:45 CST WARN  org.dinky.aop.ProcessAspect 94 processStepAround - Process null does not exist, This registration step SUBMIT_EXECUTE was abandoned
[dinky] 2024-04-22 14:39:45 CST INFO  org.dinky.service.impl.TaskServiceImpl 562 initTenantByTaskId - Init task tenan finished..
[dinky] 2024-04-22 14:39:45 CST WARN  org.dinky.aop.ProcessAspect 94 processStepAround - Process null does not exist, This registration step SUBMIT_PRECHECK was abandoned
[dinky] 2024-04-22 14:39:45 CST WARN  org.dinky.aop.ProcessAspect 94 processStepAround - Process null does not exist, This registration step SUBMIT_BUILD_CONFIG was abandoned
[dinky] 2024-04-22 14:39:45 CST INFO  org.dinky.service.impl.TaskServiceImpl 286 buildEnvSql - Start initialize FlinkSQLEnv:
[dinky] 2024-04-22 14:39:45 CST INFO  org.dinky.service.impl.TaskServiceImpl 177 prepareTask - Start check and config task, task:ods.news-flash-flash-news-sms-temp-data
[dinky] 2024-04-22 14:39:45 CST WARN  org.dinky.aop.ProcessAspect 94 processStepAround - Process null does not exist, This registration step SUBMIT_EXECUTE was abandoned
[dinky] 2024-04-22 14:39:45 CST INFO  org.dinky.service.impl.TaskServiceImpl 306 buildEnvSql - Initializing data permissions...
[dinky] 2024-04-22 14:39:45 CST WARN  org.dinky.aop.ProcessAspect 94 processStepAround - Process null does not exist, This registration step SUBMIT_BUILD_CONFIG was abandoned
[dinky] 2024-04-22 14:39:45 CST ERROR org.dinky.aop.exception.UnKnownExceptionHandler 39 unknownException - java.lang.IllegalStateException: zip file closed org.dinky.data.exception.DinkyException: java.lang.IllegalStateException: zip file closed
    at org.dinky.aop.UdfClassLoaderAspect.round(UdfClassLoaderAspect.java:58) ~[dinky-admin-1.0.1.jar:?]
    at sun.reflect.GeneratedMethodAccessor489.invoke(Unknown Source) ~[?:?]
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:1.8.0_181]
    at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_181]
    at org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethodWithGivenArgs(AbstractAspectJAdvice.java:634) ~[spring-aop-5.3.27.jar:5.3.27]
    at org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethod(AbstractAspectJAdvice.java:624) ~[spring-aop-5.3.27.jar:5.3.27]
    at org.springframework.aop.aspectj.AspectJAroundAdvice.invoke(AspectJAroundAdvice.java:72) ~[spring-aop-5.3.27.jar:5.3.27]
    at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186) ~[spring-aop-5.3.27.jar:5.3.27]
    at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) ~[spring-aop-5.3.27.jar:5.3.27]
    at org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:97) ~[spring-aop-5.3.27.jar:5.3.27]
    at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186) ~[spring-aop-5.3.27.jar:5.3.27]
    at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) ~[spring-aop-5.3.27.jar:5.3.27]
    at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:708) ~[spring-aop-5.3.27.jar:5.3.27]
    at org.dinky.service.impl.TaskServiceImpl$$EnhancerBySpringCGLIB$$ec2e6081.submitTask(<generated>) ~[dinky-admin-1.0.1.jar:?]
    at org.dinky.controller.APIController.submitTask(APIController.java:81) ~[dinky-admin-1.0.1.jar:?]
    at org.dinky.controller.APIController$$FastClassBySpringCGLIB$$685a2905.invoke(<generated>) ~[dinky-admin-1.0.1.jar:?]
    at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218) ~[spring-core-5.3.27.jar:5.3.27]
    at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:793) ~[spring-aop-5.3.27.jar:5.3.27]
    at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163) ~[spring-aop-5.3.27.jar:5.3.27]
    at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) ~[spring-aop-5.3.27.jar:5.3.27]
    at org.springframework.aop.framework.adapter.AfterReturningAdviceInterceptor.invoke(AfterReturningAdviceInterceptor.java:57) ~[spring-aop-5.3.27.jar:5.3.27]
    at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186) ~[spring-aop-5.3.27.jar:5.3.27]
    at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) ~[spring-aop-5.3.27.jar:5.3.27]
    at org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:97) ~[spring-aop-5.3.27.jar:5.3.27]
    at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186) ~[spring-aop-5.3.27.jar:5.3.27]
    at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) ~[spring-aop-5.3.27.jar:5.3.27]
    at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:708) ~[spring-aop-5.3.27.jar:5.3.27]
    at org.dinky.controller.APIController$$EnhancerBySpringCGLIB$$f7061ee5.submitTask(<generated>) ~[dinky-admin-1.0.1.jar:?]
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:1.8.0_181]
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[?:1.8.0_181]
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:1.8.0_181]
    at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_181]
    at org.springframework.web.method.support.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:205) ~[spring-web-5.3.27.jar:5.3.27]
    at org.springframework.web.method.support.InvocableHandlerMethod.invokeForRequest(InvocableHandlerMethod.java:150) ~[spring-web-5.3.27.jar:5.3.27]
    at org.springframework.web.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java:117) ~[spring-webmvc-5.3.27.jar:5.3.27]
    at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandlerMethod(RequestMappingHandlerAdapter.java:895) ~[spring-webmvc-5.3.27.jar:5.3.27]
    at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal(RequestMappingHandlerAdapter.java:808) ~[spring-webmvc-5.3.27.jar:5.3.27]
    at org.springframework.web.servlet.mvc.method.AbstractHandlerMethodAdapter.handle(AbstractHandlerMethodAdapter.java:87) ~[spring-webmvc-5.3.27.jar:5.3.27]
    at org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:1072) ~[spring-webmvc-5.3.27.jar:5.3.27]
    at org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:965) ~[spring-webmvc-5.3.27.jar:5.3.27]
    at org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:1006) ~[spring-webmvc-5.3.27.jar:5.3.27]
    at org.springframework.web.servlet.FrameworkServlet.doPost(FrameworkServlet.java:909) ~[spring-webmvc-5.3.27.jar:5.3.27]
    at javax.servlet.http.HttpServlet.service(HttpServlet.java:555) ~[tomcat-embed-core-9.0.74.jar:4.0.FR]
    at org.springframework.web.servlet.FrameworkServlet.service(FrameworkServlet.java:883) ~[spring-webmvc-5.3.27.jar:5.3.27]
    at javax.servlet.http.HttpServlet.service(HttpServlet.java:623) ~[tomcat-embed-core-9.0.74.jar:4.0.FR]
    at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:209) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:153) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at org.apache.tomcat.websocket.server.WsFilter.doFilter(WsFilter.java:51) ~[tomcat-embed-websocket-9.0.74.jar:9.0.74]
    at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:178) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:153) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at org.springframework.web.filter.CorsFilter.doFilterInternal(CorsFilter.java:91) ~[spring-web-5.3.27.jar:5.3.27]
    at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:117) ~[spring-web-5.3.27.jar:5.3.27]
    at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:178) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:153) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at com.alibaba.druid.support.http.WebStatFilter.doFilter(WebStatFilter.java:124) ~[druid-1.2.8.jar:1.2.8]
    at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:178) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:153) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at org.springframework.web.filter.RequestContextFilter.doFilterInternal(RequestContextFilter.java:100) ~[spring-web-5.3.27.jar:5.3.27]
    at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:117) ~[spring-web-5.3.27.jar:5.3.27]
    at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:178) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:153) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at cn.dev33.satoken.filter.SaPathCheckFilterForServlet.doFilter(SaPathCheckFilterForServlet.java:55) ~[sa-token-spring-boot-starter-1.37.0.jar:?]
    at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:178) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:153) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at org.springframework.web.filter.FormContentFilter.doFilterInternal(FormContentFilter.java:93) ~[spring-web-5.3.27.jar:5.3.27]
    at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:117) ~[spring-web-5.3.27.jar:5.3.27]
    at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:178) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:153) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at org.springframework.boot.actuate.metrics.web.servlet.WebMvcMetricsFilter.doFilterInternal(WebMvcMetricsFilter.java:96) ~[spring-boot-actuator-2.7.11.jar:2.7.11]
    at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:117) ~[spring-web-5.3.27.jar:5.3.27]
    at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:178) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:153) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at org.springframework.web.filter.CharacterEncodingFilter.doFilterInternal(CharacterEncodingFilter.java:201) ~[spring-web-5.3.27.jar:5.3.27]
    at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:117) ~[spring-web-5.3.27.jar:5.3.27]
    at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:178) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:153) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:167) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:90) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at org.apache.catalina.authenticator.AuthenticatorBase.invoke(AuthenticatorBase.java:481) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:130) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:93) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:74) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:343) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at org.apache.coyote.http11.Http11Processor.service(Http11Processor.java:389) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at org.apache.coyote.AbstractProcessorLight.process(AbstractProcessorLight.java:63) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at org.apache.coyote.AbstractProtocol$ConnectionHandler.process(AbstractProtocol.java:926) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at org.apache.tomcat.util.net.NioEndpoint$SocketProcessor.doRun(NioEndpoint.java:1791) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at org.apache.tomcat.util.net.SocketProcessorBase.run(SocketProcessorBase.java:52) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at org.apache.tomcat.util.threads.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1191) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at org.apache.tomcat.util.threads.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:659) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_181]
Caused by: java.lang.IllegalStateException: zip file closed
    at java.util.zip.ZipFile.ensureOpen(ZipFile.java:686) ~[?:1.8.0_181]
    at java.util.zip.ZipFile.access$200(ZipFile.java:60) ~[?:1.8.0_181]
    at java.util.zip.ZipFile$ZipEntryIterator.hasNext(ZipFile.java:508) ~[?:1.8.0_181]
    at java.util.zip.ZipFile$ZipEntryIterator.hasMoreElements(ZipFile.java:503) ~[?:1.8.0_181]
    at java.util.jar.JarFile$JarEntryIterator.hasNext(JarFile.java:253) ~[?:1.8.0_181]
    at java.util.jar.JarFile$JarEntryIterator.hasMoreElements(JarFile.java:262) ~[?:1.8.0_181]
    at cn.hutool.core.collection.EnumerationIter.hasNext(EnumerationIter.java:29) ~[hutool-all-5.8.25.jar:5.8.25]
    at cn.hutool.core.lang.ClassScanner.scanJar(ClassScanner.java:367) ~[hutool-all-5.8.25.jar:5.8.25]
    at cn.hutool.core.lang.ClassScanner.scan(ClassScanner.java:266) ~[hutool-all-5.8.25.jar:5.8.25]
    at cn.hutool.core.lang.ClassScanner.scan(ClassScanner.java:244) ~[hutool-all-5.8.25.jar:5.8.25]
    at cn.hutool.core.lang.ClassScanner.scanPackage(ClassScanner.java:180) ~[hutool-all-5.8.25.jar:5.8.25]
    at cn.hutool.core.lang.ClassScanner.scanPackageBySuper(ClassScanner.java:124) ~[hutool-all-5.8.25.jar:5.8.25]
    at cn.hutool.core.util.ClassUtil.scanPackageBySuper(ClassUtil.java:203) ~[hutool-all-5.8.25.jar:5.8.25]
    at org.dinky.service.task.BaseTask.getTask(BaseTask.java:67) ~[dinky-admin-1.0.1.jar:?]
    at org.dinky.service.impl.TaskServiceImpl.executeJob(TaskServiceImpl.java:191) ~[dinky-admin-1.0.1.jar:?]
    at org.dinky.service.impl.TaskServiceImpl$$FastClassBySpringCGLIB$$22087f7c.invoke(<generated>) ~[dinky-admin-1.0.1.jar:?]
    at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218) ~[spring-core-5.3.27.jar:5.3.27]
    at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:793) ~[spring-aop-5.3.27.jar:5.3.27]
    at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163) ~[spring-aop-5.3.27.jar:5.3.27]
    at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) ~[spring-aop-5.3.27.jar:5.3.27]
    at org.springframework.aop.aspectj.MethodInvocationProceedingJoinPoint.proceed(MethodInvocationProceedingJoinPoint.java:89) ~[spring-aop-5.3.27.jar:5.3.27]
    at org.dinky.aop.ProcessAspect.processStepAround(ProcessAspect.java:98) ~[dinky-admin-1.0.1.jar:?]
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:1.8.0_181]
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[?:1.8.0_181]
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:1.8.0_181]
    at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_181]
    at org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethodWithGivenArgs(AbstractAspectJAdvice.java:634) ~[spring-aop-5.3.27.jar:5.3.27]
    at org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethod(AbstractAspectJAdvice.java:624) ~[spring-aop-5.3.27.jar:5.3.27]
    at org.springframework.aop.aspectj.AspectJAroundAdvice.invoke(AspectJAroundAdvice.java:72) ~[spring-aop-5.3.27.jar:5.3.27]
    at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:175) ~[spring-aop-5.3.27.jar:5.3.27]
    at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) ~[spring-aop-5.3.27.jar:5.3.27]
    at org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:97) ~[spring-aop-5.3.27.jar:5.3.27]
    at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186) ~[spring-aop-5.3.27.jar:5.3.27]
    at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) ~[spring-aop-5.3.27.jar:5.3.27]
    at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:708) ~[spring-aop-5.3.27.jar:5.3.27]
    at org.dinky.service.impl.TaskServiceImpl$$EnhancerBySpringCGLIB$$ec2e6081.executeJob(<generated>) ~[dinky-admin-1.0.1.jar:?]
    at org.dinky.service.impl.TaskServiceImpl.submitTask(TaskServiceImpl.java:319) ~[dinky-admin-1.0.1.jar:?]
    at org.dinky.service.impl.TaskServiceImpl$$FastClassBySpringCGLIB$$22087f7c.invoke(<generated>) ~[dinky-admin-1.0.1.jar:?]
    at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218) ~[spring-core-5.3.27.jar:5.3.27]
    at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:793) ~[spring-aop-5.3.27.jar:5.3.27]
    at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163) ~[spring-aop-5.3.27.jar:5.3.27]
    at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) ~[spring-aop-5.3.27.jar:5.3.27]
    at org.springframework.aop.aspectj.MethodInvocationProceedingJoinPoint.proceed(MethodInvocationProceedingJoinPoint.java:89) ~[spring-aop-5.3.27.jar:5.3.27]
    at org.dinky.aop.UdfClassLoaderAspect.round(UdfClassLoaderAspect.java:55) ~[dinky-admin-1.0.1.jar:?]
    ... 91 more

[dinky] 2024-04-22 14:39:45 CST INFO  org.dinky.service.impl.TaskServiceImpl 286 buildEnvSql - Start initialize FlinkSQLEnv:
[dinky] 2024-04-22 14:39:45 CST INFO  org.dinky.service.impl.TaskServiceImpl 308 buildEnvSql - Finish initialize FlinkSQLEnv.
[dinky] 2024-04-22 14:39:45 CST INFO  org.dinky.service.impl.TaskServiceImpl 223 buildJobSubmitConfig - Init gateway config, type:yarn-application
[dinky] 2024-04-22 14:39:45 CST INFO  org.dinky.service.impl.TaskServiceImpl 177 prepareTask - Start check and config task, task:ods.news-flash-flash-news-sms-template
[dinky] 2024-04-22 14:39:45 CST WARN  org.dinky.aop.ProcessAspect 94 processStepAround - Process null does not exist, This registration step SUBMIT_EXECUTE was abandoned
[dinky] 2024-04-22 14:39:45 CST INFO  org.dinky.service.impl.TaskServiceImpl 236 buildJobSubmitConfig - Init remote cluster
[dinky] 2024-04-22 14:39:45 CST INFO  org.dinky.service.impl.TaskServiceImpl 306 buildEnvSql - Initializing data permissions...
[dinky] 2024-04-22 14:39:45 CST WARN  org.dinky.aop.ProcessAspect 94 processStepAround - Process null does not exist, This registration step SUBMIT_BUILD_CONFIG was abandoned
[dinky] 2024-04-22 14:39:45 CST INFO  org.dinky.service.impl.TaskServiceImpl 286 buildEnvSql - Start initialize FlinkSQLEnv:
[dinky] 2024-04-22 14:39:45 CST INFO  org.dinky.service.impl.TaskServiceImpl 308 buildEnvSql - Finish initialize FlinkSQLEnv.
[dinky] 2024-04-22 14:39:45 CST INFO  org.dinky.service.impl.TaskServiceImpl 223 buildJobSubmitConfig - Init gateway config, type:yarn-application
[dinky] 2024-04-22 14:39:45 CST INFO  org.dinky.service.impl.TaskServiceImpl 306 buildEnvSql - Initializing data permissions...
[dinky] 2024-04-22 14:39:45 CST INFO  org.dinky.service.task.FlinkSqlTask 67 execute - Initializing Flink job config...
[dinky] 2024-04-22 14:39:45 CST INFO  org.dinky.service.impl.TaskServiceImpl 236 buildJobSubmitConfig - Init remote cluster
[dinky] 2024-04-22 14:39:45 CST INFO  org.dinky.service.impl.TaskServiceImpl 308 buildEnvSql - Finish initialize FlinkSQLEnv.
[dinky] 2024-04-22 14:39:45 CST INFO  org.dinky.service.impl.TaskServiceImpl 223 buildJobSubmitConfig - Init gateway config, type:yarn-application
[dinky] 2024-04-22 14:39:45 CST INFO  org.dinky.service.impl.TaskServiceImpl 236 buildJobSubmitConfig - Init remote cluster
[dinky] 2024-04-22 14:39:45 CST INFO  org.dinky.service.impl.TaskServiceImpl 306 buildEnvSql - Initializing data permissions...
[dinky] 2024-04-22 14:39:45 CST INFO  org.dinky.service.impl.TaskServiceImpl 253 buildJobConfig - Init gateway config, type:yarn-application
[dinky] 2024-04-22 14:39:45 CST INFO  org.dinky.service.impl.TaskServiceImpl 308 buildEnvSql - Finish initialize FlinkSQLEnv.
[dinky] 2024-04-22 14:39:45 CST INFO  org.dinky.service.impl.TaskServiceImpl 223 buildJobSubmitConfig - Init gateway config, type:yarn-application
[dinky] 2024-04-22 14:39:45 CST INFO  org.dinky.service.impl.TaskServiceImpl 275 buildJobConfig - Init remote cluster
[dinky] 2024-04-22 14:39:45 CST INFO  org.dinky.service.impl.TaskServiceImpl 236 buildJobSubmitConfig - Init remote cluster
[dinky] 2024-04-22 14:39:45 CST INFO  org.dinky.job.builder.JobUDFBuilder 115 run - A total of 0 UDF have been Init.
[dinky] 2024-04-22 14:39:45 CST INFO  org.dinky.job.builder.JobUDFBuilder 116 run - Initializing Flink UDF...Finish
[dinky] 2024-04-22 14:39:45 CST INFO  org.dinky.utils.KerberosUtil 58 authenticate - Simple authentication mode
[dinky] 2024-04-22 14:39:45 CST INFO  org.dinky.cluster.FlinkCluster 63 executeSocketTest - Flink jobManager 地址排除 -- vm-mysteel-cdh-dw-dn02.mysteeltech.com:33370
[dinky] 2024-04-22 14:39:45 CST INFO  org.dinky.cluster.FlinkCluster 63 executeSocketTest - Flink jobManager 地址排除 -- vm-mysteel-cdh-dw-dn02.mysteeltech.com:33370
[dinky] 2024-04-22 14:39:45 CST INFO  org.dinky.service.task.FlinkSqlTask 67 execute - Initializing Flink job config...
[dinky] 2024-04-22 14:39:45 CST ERROR org.dinky.aop.exception.WebExceptionHandler 64 busException - BusException: org.dinky.data.exception.BusException: 集群地址暂不可用
    at org.dinky.service.impl.TaskServiceImpl.buildJobConfig(TaskServiceImpl.java:279) ~[dinky-admin-1.0.1.jar:?]
    at org.dinky.service.impl.TaskServiceImpl.savepointTaskJob(TaskServiceImpl.java:458) ~[dinky-admin-1.0.1.jar:?]
    at org.dinky.service.impl.TaskServiceImpl$$FastClassBySpringCGLIB$$22087f7c.invoke(<generated>) ~[dinky-admin-1.0.1.jar:?]
    at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218) ~[spring-core-5.3.27.jar:5.3.27]
    at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:793) ~[spring-aop-5.3.27.jar:5.3.27]
    at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163) ~[spring-aop-5.3.27.jar:5.3.27]
    at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) ~[spring-aop-5.3.27.jar:5.3.27]
    at org.springframework.aop.aspectj.MethodInvocationProceedingJoinPoint.proceed(MethodInvocationProceedingJoinPoint.java:89) ~[spring-aop-5.3.27.jar:5.3.27]
    at org.dinky.aop.UdfClassLoaderAspect.round(UdfClassLoaderAspect.java:55) ~[dinky-admin-1.0.1.jar:?]
    at sun.reflect.GeneratedMethodAccessor489.invoke(Unknown Source) ~[?:?]
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:1.8.0_181]
    at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_181]
    at org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethodWithGivenArgs(AbstractAspectJAdvice.java:634) ~[spring-aop-5.3.27.jar:5.3.27]
    at org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethod(AbstractAspectJAdvice.java:624) ~[spring-aop-5.3.27.jar:5.3.27]
    at org.springframework.aop.aspectj.AspectJAroundAdvice.invoke(AspectJAroundAdvice.java:72) ~[spring-aop-5.3.27.jar:5.3.27]
    at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186) ~[spring-aop-5.3.27.jar:5.3.27]
    at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) ~[spring-aop-5.3.27.jar:5.3.27]
    at org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:97) ~[spring-aop-5.3.27.jar:5.3.27]
    at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186) ~[spring-aop-5.3.27.jar:5.3.27]
    at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) ~[spring-aop-5.3.27.jar:5.3.27]
    at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:708) ~[spring-aop-5.3.27.jar:5.3.27]
    at org.dinky.service.impl.TaskServiceImpl$$EnhancerBySpringCGLIB$$ec2e6081.savepointTaskJob(<generated>) ~[dinky-admin-1.0.1.jar:?]
    at org.dinky.controller.APIController.savepointTask(APIController.java:92) ~[dinky-admin-1.0.1.jar:?]
    at org.dinky.controller.APIController$$FastClassBySpringCGLIB$$685a2905.invoke(<generated>) ~[dinky-admin-1.0.1.jar:?]
    at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218) ~[spring-core-5.3.27.jar:5.3.27]
    at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:793) ~[spring-aop-5.3.27.jar:5.3.27]
    at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163) ~[spring-aop-5.3.27.jar:5.3.27]
    at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) ~[spring-aop-5.3.27.jar:5.3.27]
    at org.springframework.aop.framework.adapter.AfterReturningAdviceInterceptor.invoke(AfterReturningAdviceInterceptor.java:57) ~[spring-aop-5.3.27.jar:5.3.27]
    at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186) ~[spring-aop-5.3.27.jar:5.3.27]
    at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) ~[spring-aop-5.3.27.jar:5.3.27]
    at org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:97) ~[spring-aop-5.3.27.jar:5.3.27]
    at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186) ~[spring-aop-5.3.27.jar:5.3.27]
    at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) ~[spring-aop-5.3.27.jar:5.3.27]
    at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:708) ~[spring-aop-5.3.27.jar:5.3.27]
    at org.dinky.controller.APIController$$EnhancerBySpringCGLIB$$f7061ee5.savepointTask(<generated>) ~[dinky-admin-1.0.1.jar:?]
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:1.8.0_181]
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[?:1.8.0_181]
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:1.8.0_181]
    at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_181]
    at org.springframework.web.method.support.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:205) ~[spring-web-5.3.27.jar:5.3.27]
    at org.springframework.web.method.support.InvocableHandlerMethod.invokeForRequest(InvocableHandlerMethod.java:150) ~[spring-web-5.3.27.jar:5.3.27]
    at org.springframework.web.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java:117) ~[spring-webmvc-5.3.27.jar:5.3.27]
    at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandlerMethod(RequestMappingHandlerAdapter.java:895) ~[spring-webmvc-5.3.27.jar:5.3.27]
    at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal(RequestMappingHandlerAdapter.java:808) ~[spring-webmvc-5.3.27.jar:5.3.27]
    at org.springframework.web.servlet.mvc.method.AbstractHandlerMethodAdapter.handle(AbstractHandlerMethodAdapter.java:87) ~[spring-webmvc-5.3.27.jar:5.3.27]
    at org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:1072) ~[spring-webmvc-5.3.27.jar:5.3.27]
    at org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:965) ~[spring-webmvc-5.3.27.jar:5.3.27]
    at org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:1006) ~[spring-webmvc-5.3.27.jar:5.3.27]
    at org.springframework.web.servlet.FrameworkServlet.doPost(FrameworkServlet.java:909) ~[spring-webmvc-5.3.27.jar:5.3.27]
    at javax.servlet.http.HttpServlet.service(HttpServlet.java:555) ~[tomcat-embed-core-9.0.74.jar:4.0.FR]
    at org.springframework.web.servlet.FrameworkServlet.service(FrameworkServlet.java:883) ~[spring-webmvc-5.3.27.jar:5.3.27]
    at javax.servlet.http.HttpServlet.service(HttpServlet.java:623) ~[tomcat-embed-core-9.0.74.jar:4.0.FR]
    at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:209) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:153) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at org.apache.tomcat.websocket.server.WsFilter.doFilter(WsFilter.java:51) ~[tomcat-embed-websocket-9.0.74.jar:9.0.74]
    at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:178) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:153) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at org.springframework.web.filter.CorsFilter.doFilterInternal(CorsFilter.java:91) ~[spring-web-5.3.27.jar:5.3.27]
    at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:117) ~[spring-web-5.3.27.jar:5.3.27]
    at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:178) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:153) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at com.alibaba.druid.support.http.WebStatFilter.doFilter(WebStatFilter.java:124) ~[druid-1.2.8.jar:1.2.8]
    at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:178) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:153) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at org.springframework.web.filter.RequestContextFilter.doFilterInternal(RequestContextFilter.java:100) ~[spring-web-5.3.27.jar:5.3.27]
    at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:117) ~[spring-web-5.3.27.jar:5.3.27]
    at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:178) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:153) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at cn.dev33.satoken.filter.SaPathCheckFilterForServlet.doFilter(SaPathCheckFilterForServlet.java:55) ~[sa-token-spring-boot-starter-1.37.0.jar:?]
    at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:178) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:153) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at org.springframework.web.filter.FormContentFilter.doFilterInternal(FormContentFilter.java:93) ~[spring-web-5.3.27.jar:5.3.27]
    at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:117) ~[spring-web-5.3.27.jar:5.3.27]
    at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:178) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:153) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at org.springframework.boot.actuate.metrics.web.servlet.WebMvcMetricsFilter.doFilterInternal(WebMvcMetricsFilter.java:96) ~[spring-boot-actuator-2.7.11.jar:2.7.11]
    at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:117) ~[spring-web-5.3.27.jar:5.3.27]
    at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:178) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:153) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at org.springframework.web.filter.CharacterEncodingFilter.doFilterInternal(CharacterEncodingFilter.java:201) ~[spring-web-5.3.27.jar:5.3.27]
    at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:117) ~[spring-web-5.3.27.jar:5.3.27]
    at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:178) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:153) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:167) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:90) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at org.apache.catalina.authenticator.AuthenticatorBase.invoke(AuthenticatorBase.java:481) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:130) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:93) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:74) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:343) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at org.apache.coyote.http11.Http11Processor.service(Http11Processor.java:389) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at org.apache.coyote.AbstractProcessorLight.process(AbstractProcessorLight.java:63) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at org.apache.coyote.AbstractProtocol$ConnectionHandler.process(AbstractProtocol.java:926) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at org.apache.tomcat.util.net.NioEndpoint$SocketProcessor.doRun(NioEndpoint.java:1791) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at org.apache.tomcat.util.net.SocketProcessorBase.run(SocketProcessorBase.java:52) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at org.apache.tomcat.util.threads.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1191) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at org.apache.tomcat.util.threads.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:659) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61) ~[tomcat-embed-core-9.0.74.jar:9.0.74]
    at java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_181]

[dinky] 2024-04-22 14:39:45 CST INFO  org.dinky.job.builder.JobUDFBuilder 115 run - A total of 0 UDF have been Init.
[dinky] 2024-04-22 14:39:45 CST INFO  org.dinky.job.builder.JobUDFBuilder 116 run - Initializing Flink UDF...Finish
[dinky] 2024-04-22 14:39:45 CST INFO  org.dinky.utils.KerberosUtil 58 authenticate - Simple authentication mode
[dinky] 2024-04-22 14:39:45 CST INFO  org.dinky.service.task.FlinkSqlTask 67 execute - Initializing Flink job config...
[dinky] 2024-04-22 14:39:45 CST INFO  org.dinky.service.task.FlinkSqlTask 67 execute - Initializing Flink job config...
[dinky] 2024-04-22 14:39:45 CST INFO  com.netease.arctic.utils.CatalogUtil 129 buildMetaStore - TableMetaStore use auth config in catalog meta, authType is simple
[dinky] 2024-04-22 14:39:45 CST INFO  org.dinky.job.builder.JobUDFBuilder 115 run - A total of 0 UDF have been Init.
[dinky] 2024-04-22 14:39:45 CST INFO  com.netease.arctic.utils.CatalogUtil 148 buildMetaStore - TableMetaStore use auth config in properties, authType is simple
[dinky] 2024-04-22 14:39:45 CST INFO  org.dinky.job.builder.JobUDFBuilder 116 run - Initializing Flink UDF...Finish
[dinky] 2024-04-22 14:39:45 CST INFO  com.netease.arctic.table.TableMetaStore$Builder 744 build - Construct TableMetaStore with authMethod:SIMPLE, hadoopUsername:hdfs, krbPrincipal:null
[dinky] 2024-04-22 14:39:45 CST INFO  org.dinky.utils.KerberosUtil 58 authenticate - Simple authentication mode
[dinky] 2024-04-22 14:39:45 CST INFO  org.dinky.job.builder.JobUDFBuilder 115 run - A total of 0 UDF have been Init.
[dinky] 2024-04-22 14:39:45 CST INFO  com.netease.arctic.utils.CatalogUtil 129 buildMetaStore - TableMetaStore use auth config in catalog meta, authType is simple
[dinky] 2024-04-22 14:39:45 CST INFO  org.dinky.job.builder.JobUDFBuilder 116 run - Initializing Flink UDF...Finish
[dinky] 2024-04-22 14:39:45 CST INFO  com.netease.arctic.utils.CatalogUtil 148 buildMetaStore - TableMetaStore use auth config in properties, authType is simple
[dinky] 2024-04-22 14:39:45 CST INFO  org.dinky.utils.KerberosUtil 58 authenticate - Simple authentication mode
[dinky] 2024-04-22 14:39:45 CST INFO  com.netease.arctic.table.TableMetaStore$Builder 744 build - Construct TableMetaStore with authMethod:SIMPLE, hadoopUsername:hdfs, krbPrincipal:null
[dinky] 2024-04-22 14:39:45 CST INFO  com.netease.arctic.utils.CatalogUtil 129 buildMetaStore - TableMetaStore use auth config in catalog meta, authType is simple
[dinky] 2024-04-22 14:39:45 CST INFO  com.netease.arctic.utils.CatalogUtil 148 buildMetaStore - TableMetaStore use auth config in properties, authType is simple
[dinky] 2024-04-22 14:39:45 CST INFO  org.dinky.utils.KerberosUtil 58 authenticate - Simple authentication mode
[dinky] 2024-04-22 14:39:45 CST INFO  com.netease.arctic.table.TableMetaStore$Builder 744 build - Construct TableMetaStore with authMethod:SIMPLE, hadoopUsername:hdfs, krbPrincipal:null
[dinky] 2024-04-22 14:39:45 CST INFO  com.netease.arctic.utils.CatalogUtil 129 buildMetaStore - TableMetaStore use auth config in catalog meta, authType is simple
[dinky] 2024-04-22 14:39:45 CST INFO  com.netease.arctic.utils.CatalogUtil 148 buildMetaStore - TableMetaStore use auth config in properties, authType is simple
[dinky] 2024-04-22 14:39:45 CST INFO  com.netease.arctic.table.TableMetaStore$Builder 744 build - Construct TableMetaStore with authMethod:SIMPLE, hadoopUsername:hdfs, krbPrincipal:null
[dinky] 2024-04-22 14:39:45 CST INFO  org.dinky.utils.KerberosUtil 58 authenticate - Simple authentication mode
[dinky] 2024-04-22 14:39:45 CST INFO  com.netease.arctic.utils.CatalogUtil 129 buildMetaStore - TableMetaStore use auth config in catalog meta, authType is simple
[dinky] 2024-04-22 14:39:45 CST INFO  com.netease.arctic.utils.CatalogUtil 148 buildMetaStore - TableMetaStore use auth config in properties, authType is simple
[dinky] 2024-04-22 14:39:45 CST INFO  com.netease.arctic.table.TableMetaStore$Builder 744 build - Construct TableMetaStore with authMethod:SIMPLE, hadoopUsername:hdfs, krbPrincipal:null
[dinky] 2024-04-22 14:39:45 CST INFO  com.netease.arctic.utils.CatalogUtil 129 buildMetaStore - TableMetaStore use auth config in catalog meta, authType is simple
[dinky] 2024-04-22 14:39:45 CST INFO  com.netease.arctic.utils.CatalogUtil 148 buildMetaStore - TableMetaStore use auth config in properties, authType is simple
[dinky] 2024-04-22 14:39:45 CST INFO  com.netease.arctic.table.TableMetaStore$Builder 744 build - Construct TableMetaStore with authMethod:SIMPLE, hadoopUsername:hdfs, krbPrincipal:null
[dinky] 2024-04-22 14:39:45 CST INFO  com.netease.arctic.utils.CatalogUtil 129 buildMetaStore - TableMetaStore use auth config in catalog meta, authType is simple
[dinky] 2024-04-22 14:39:45 CST INFO  com.netease.arctic.utils.CatalogUtil 148 buildMetaStore - TableMetaStore use auth config in properties, authType is simple
[dinky] 2024-04-22 14:39:45 CST INFO  com.netease.arctic.table.TableMetaStore$Builder 744 build - Construct TableMetaStore with authMethod:SIMPLE, hadoopUsername:hdfs, krbPrincipal:null
[dinky] 2024-04-22 14:39:45 CST INFO  com.netease.arctic.utils.CatalogUtil 129 buildMetaStore - TableMetaStore use auth config in catalog meta, authType is simple
[dinky] 2024-04-22 14:39:45 CST INFO  com.netease.arctic.utils.CatalogUtil 148 buildMetaStore - TableMetaStore use auth config in properties, authType is simple
[dinky] 2024-04-22 14:39:45 CST INFO  com.netease.arctic.table.TableMetaStore$Builder 744 build - Construct TableMetaStore with authMethod:SIMPLE, hadoopUsername:hdfs, krbPrincipal:null
[dinky] 2024-04-22 14:39:45 CST INFO  org.dinky.utils.KerberosUtil 58 authenticate - Simple authentication mode
[dinky] 2024-04-22 14:39:45 CST INFO  org.dinky.utils.KerberosUtil 58 authenticate - Simple authentication mode
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: jobmanager.rpc.address, localhost
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: jobmanager.rpc.address, localhost
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: jobmanager.rpc.port, 6123
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: jobmanager.rpc.port, 6123
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: jobmanager.rpc.address, localhost
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: jobmanager.rpc.address, localhost
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: jobmanager.memory.process.size, 1024m
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: jobmanager.memory.process.size, 1024m
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: jobmanager.rpc.port, 6123
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: jobmanager.rpc.port, 6123
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: taskmanager.numberOfTaskSlots, 1
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: taskmanager.numberOfTaskSlots, 1
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: jobmanager.memory.process.size, 1024m
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: jobmanager.memory.process.size, 1024m
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: parallelism.default, 1
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: parallelism.default, 1
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: taskmanager.numberOfTaskSlots, 1
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: taskmanager.numberOfTaskSlots, 1
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: env.java.opts, "-Dfile.encoding=UTF-8"
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: parallelism.default, 1
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: env.java.opts, "-Dfile.encoding=UTF-8"
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: parallelism.default, 1
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: state.checkpoints.num-retained, 10
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: env.java.opts, "-Dfile.encoding=UTF-8"
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: state.checkpoints.num-retained, 10
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: env.java.opts, "-Dfile.encoding=UTF-8"
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: state.checkpoints.num-retained, 10
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: execution.checkpointing.mode, EXACTLY_ONCE
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: execution.checkpointing.mode, EXACTLY_ONCE
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: execution.checkpointing.mode, EXACTLY_ONCE
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: execution.checkpointing.externalized-checkpoint-retention, RETAIN_ON_CANCELLATION
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: state.checkpoints.num-retained, 10
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: execution.checkpointing.externalized-checkpoint-retention, RETAIN_ON_CANCELLATION
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: execution.checkpointing.externalized-checkpoint-retention, RETAIN_ON_CANCELLATION
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: state.backend, rocksdb
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: execution.checkpointing.mode, EXACTLY_ONCE
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: state.backend, rocksdb
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: state.backend, rocksdb
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: state.checkpoints.dir, hdfs:///user/flink/checkpoints
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: execution.checkpointing.externalized-checkpoint-retention, RETAIN_ON_CANCELLATION
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: state.checkpoints.dir, hdfs:///user/flink/checkpoints
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: state.checkpoints.dir, hdfs:///user/flink/checkpoints
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: state.savepoints.dir, hdfs:///user/flink/savepoints
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: state.backend, rocksdb
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: state.savepoints.dir, hdfs:///user/flink/savepoints
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: state.savepoints.dir, hdfs:///user/flink/savepoints
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: jobmanager.execution.failover-strategy, region
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: state.checkpoints.dir, hdfs:///user/flink/checkpoints
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: jobmanager.execution.failover-strategy, region
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: jobmanager.execution.failover-strategy, region
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: state.savepoints.dir, hdfs:///user/flink/savepoints
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: classloader.check-leaked-classloader, false
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: classloader.check-leaked-classloader, false
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: classloader.check-leaked-classloader, false
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: jobmanager.execution.failover-strategy, region
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: classloader.resolve-order, parent-first
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: classloader.resolve-order, parent-first
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: classloader.resolve-order, parent-first
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: classloader.check-leaked-classloader, false
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: jobmanager.archive.fs.dir, hdfs:///user/flink/completed-jobs/
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: jobmanager.archive.fs.dir, hdfs:///user/flink/completed-jobs/
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: jobmanager.archive.fs.dir, hdfs:///user/flink/completed-jobs/
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: classloader.resolve-order, parent-first
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: historyserver.web.address, vm-mysteel-cdh-dw-dn07
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: historyserver.web.address, vm-mysteel-cdh-dw-dn07
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: historyserver.web.address, vm-mysteel-cdh-dw-dn07
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: historyserver.web.port, 8082
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: jobmanager.archive.fs.dir, hdfs:///user/flink/completed-jobs/
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: historyserver.web.port, 8082
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: historyserver.web.port, 8082
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: historyserver.archive.fs.dir, hdfs:///user/flink/completed-jobs/
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: historyserver.web.address, vm-mysteel-cdh-dw-dn07
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: historyserver.archive.fs.dir, hdfs:///user/flink/completed-jobs/
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: historyserver.archive.fs.dir, hdfs:///user/flink/completed-jobs/
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: historyserver.web.port, 8082
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: historyserver.archive.fs.refresh-interval, 10000
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: historyserver.archive.fs.refresh-interval, 10000
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: historyserver.archive.fs.refresh-interval, 10000
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: historyserver.archive.fs.dir, hdfs:///user/flink/completed-jobs/
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: historyserver.archive.clean-expired-jobs, true
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: historyserver.archive.clean-expired-jobs, true
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: historyserver.archive.clean-expired-jobs, true
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: historyserver.archive.fs.refresh-interval, 10000
[dinky] 2024-04-22 14:39:45 CST WARN  org.apache.flink.yarn.configuration.YarnLogConfigUtil 73 discoverLogConfigFile - The configuration directory ('/opt/flink-1.15.3/conf') already contains a LOG4J config file.If you want to use logback, then please delete or rename the log configuration file.
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.configuration.GlobalConfiguration 213 loadYAMLResource - Loading configuration property: historyserver.archive.clean-expired-jobs, true
[dinky] 2024-04-22 14:39:45 CST WARN  org.apache.flink.yarn.configuration.YarnLogConfigUtil 73 discoverLogConfigFile - The configuration directory ('/opt/flink-1.15.3/conf') already contains a LOG4J config file.If you want to use logback, then please delete or rename the log configuration file.
[dinky] 2024-04-22 14:39:45 CST WARN  org.apache.flink.yarn.configuration.YarnLogConfigUtil 73 discoverLogConfigFile - The configuration directory ('/opt/flink-1.15.3/conf') already contains a LOG4J config file.If you want to use logback, then please delete or rename the log configuration file.
[dinky] 2024-04-22 14:39:45 CST WARN  org.apache.flink.yarn.configuration.YarnLogConfigUtil 73 discoverLogConfigFile - The configuration directory ('/opt/flink-1.15.3/conf') already contains a LOG4J config file.If you want to use logback, then please delete or rename the log configuration file.
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.yarn.YarnClusterDescriptor 208 getLocalFlinkDistPath - No path for the flink jar passed. Using the location of class org.apache.flink.yarn.YarnClusterDescriptor to locate the jar
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.yarn.YarnClusterDescriptor 208 getLocalFlinkDistPath - No path for the flink jar passed. Using the location of class org.apache.flink.yarn.YarnClusterDescriptor to locate the jar
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.yarn.YarnClusterDescriptor 208 getLocalFlinkDistPath - No path for the flink jar passed. Using the location of class org.apache.flink.yarn.YarnClusterDescriptor to locate the jar
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.yarn.YarnClusterDescriptor 208 getLocalFlinkDistPath - No path for the flink jar passed. Using the location of class org.apache.flink.yarn.YarnClusterDescriptor to locate the jar
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.yarn.YarnClusterDescriptor 605 deployInternal - Cluster specification: ClusterSpecification{masterMemoryMB=1024, taskManagerMemoryMB=2048, slotsPerTaskManager=1}
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.yarn.YarnClusterDescriptor 605 deployInternal - Cluster specification: ClusterSpecification{masterMemoryMB=1024, taskManagerMemoryMB=2048, slotsPerTaskManager=1}
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.yarn.YarnClusterDescriptor 605 deployInternal - Cluster specification: ClusterSpecification{masterMemoryMB=1024, taskManagerMemoryMB=2048, slotsPerTaskManager=1}
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.yarn.YarnClusterDescriptor 605 deployInternal - Cluster specification: ClusterSpecification{masterMemoryMB=1024, taskManagerMemoryMB=2048, slotsPerTaskManager=1}
[dinky] 2024-04-22 14:39:45 CST WARN  org.apache.flink.core.plugin.PluginConfig 69 getPluginsDir - The plugins directory [plugins] does not exist.
[dinky] 2024-04-22 14:39:45 CST WARN  org.apache.flink.core.plugin.PluginConfig 69 getPluginsDir - The plugins directory [plugins] does not exist.
[dinky] 2024-04-22 14:39:45 CST WARN  org.apache.flink.core.plugin.PluginConfig 69 getPluginsDir - The plugins directory [plugins] does not exist.
[dinky] 2024-04-22 14:39:45 CST WARN  org.apache.flink.core.plugin.PluginConfig 69 getPluginsDir - The plugins directory [plugins] does not exist.
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.runtime.util.config.memory.ProcessMemoryUtils 330 capToMinMax - The derived from fraction jvm overhead memory (102.400mb (107374184 bytes)) is less than its min value 192.000mb (201326592 bytes), min value will be used instead
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.runtime.util.config.memory.ProcessMemoryUtils 330 capToMinMax - The derived from fraction jvm overhead memory (102.400mb (107374184 bytes)) is less than its min value 192.000mb (201326592 bytes), min value will be used instead
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.yarn.YarnClusterDescriptor 1239 startAppMaster - Submitting application master application_1711554512049_39660
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.yarn.YarnClusterDescriptor 1239 startAppMaster - Submitting application master application_1711554512049_39658
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.runtime.util.config.memory.ProcessMemoryUtils 330 capToMinMax - The derived from fraction jvm overhead memory (102.400mb (107374184 bytes)) is less than its min value 192.000mb (201326592 bytes), min value will be used instead
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.yarn.YarnClusterDescriptor 1239 startAppMaster - Submitting application master application_1711554512049_39659
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.runtime.util.config.memory.ProcessMemoryUtils 330 capToMinMax - The derived from fraction jvm overhead memory (102.400mb (107374184 bytes)) is less than its min value 192.000mb (201326592 bytes), min value will be used instead
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.yarn.YarnClusterDescriptor 1239 startAppMaster - Submitting application master application_1711554512049_39661
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.hadoop.yarn.client.api.impl.YarnClientImpl 310 submitApplication - Submitted application application_1711554512049_39660
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.hadoop.yarn.client.api.impl.YarnClientImpl 310 submitApplication - Submitted application application_1711554512049_39658
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.yarn.YarnClusterDescriptor 1242 startAppMaster - Waiting for the cluster to be allocated
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.yarn.YarnClusterDescriptor 1242 startAppMaster - Waiting for the cluster to be allocated
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.yarn.YarnClusterDescriptor 1277 startAppMaster - Deploying cluster, current state ACCEPTED
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.yarn.YarnClusterDescriptor 1277 startAppMaster - Deploying cluster, current state ACCEPTED
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.hadoop.yarn.client.api.impl.YarnClientImpl 310 submitApplication - Submitted application application_1711554512049_39659
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.yarn.YarnClusterDescriptor 1242 startAppMaster - Waiting for the cluster to be allocated
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.yarn.YarnClusterDescriptor 1277 startAppMaster - Deploying cluster, current state ACCEPTED
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.hadoop.yarn.client.api.impl.YarnClientImpl 310 submitApplication - Submitted application application_1711554512049_39661
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.yarn.YarnClusterDescriptor 1242 startAppMaster - Waiting for the cluster to be allocated
[dinky] 2024-04-22 14:39:45 CST INFO  org.apache.flink.yarn.YarnClusterDescriptor 1277 startAppMaster - Deploying cluster, current state ACCEPTED

How to reproduce

海豚版本3.2.1，在海豚上配置5个以上dinky任务，并同时执行

Anything else

No response

Version

1.0.0

Are you willing to submit PR?

Code of Conduct

github-actions[bot] commented 1 month ago

Hello @, this issue has not been active for more than 30 days. This issue will be closed in 7 days if there is no response. If you have any questions, you can comment and reply.

你好 @, 这个 issue 30 天内没有活跃，7 天后将关闭，如需回复，可以评论回复。