Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

dolphinscheduler calls dinky tasks and concurrent execution exceptions #3400

Open
2 of 3 tasks
pepperago opened this issue Apr 15, 2024 · 0 comments
Open
2 of 3 tasks

dolphinscheduler calls dinky tasks and concurrent execution exceptions #3400

pepperago opened this issue Apr 15, 2024 · 0 comments
Assignees
@gaoyan1998 @zackyoungh
Labels
Bug Something isn't working P2 level 2
Milestone
1.0.3

Comments

@pepperago
Copy link

pepperago commented Apr 15, 2024 •
edited

Search before asking

  • I had searched in the issues and found no similar issues.

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?

  • Yes I am willing to submit a PR!

Code of Conduct
@pepperago pepperago added Bug Something isn't working Waiting for reply Waiting for reply labels Apr 15, 2024
@aiwenmo aiwenmo removed the Waiting for reply Waiting for reply label Apr 18, 2024
@gaoyan1998 gaoyan1998 added P1 level 1 P2 level 2 and removed P1 level 1 labels May 6, 2024
@Zzm0809 Zzm0809 mentioned this issue May 6, 2024
Open
3 tasks
@gaoyan1998 gaoyan1998 added this to the 1.0.3 milestone May 20, 2024
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees

@gaoyan1998 gaoyan1998

@zackyoungh zackyoungh

Labels
Bug Something isn't working P2 level 2
Projects
Dinky Roadmap
Status: ToDo
Milestone
1.0.3
Development

No branches or pull requests
4 participants
@aiwenmo @gaoyan1998 @zackyoungh @pepperago