Spring Cloud Dataflow и запланированные задачи - PullRequest
1 голос
/ 13 марта 2020

У меня установлен поток данных Spring Cloud в кластере Openshift. Я пытаюсь зарегистрировать приложение, затем создать задачу, и все в порядке, но когда я пытаюсь запланировать задачу, я получаю следующее исключение:

java .lang.IllegalArgumentException: Unable создать каталог для локального репозитория:? /. m2 / repository по адресу org.springframework.util.Assert.isTrue (Assert. java: 118) ~ [spring-core-5.2.3.RELEASE.jar! /: 5.2. 3.RELEASE] at org.springframework.cloud.deployer.resource.maven.MavenArtifactResolver. (MavenArtifactResolver. java: 114) ~ [spring-cloud-deployer-resource-maven-2.2.0.RELEASE.jar! /: 2.2.0.RELEASE] at org.springframework.cloud.deployer.resource.maven.MavenResource. (MavenResource. java: 122) ~ [spring-cloud-deployer-resource-maven-2.2.0.RELEASE.jar! /:2.2.0.RELEASE] at org.springframework.cloud.deployer.resource.maven.MavenResource.parse (MavenResource. java: 268) ~ [spring-cloud-deployer-resource-maven-2.2.0.RELEASE .jar! /: 2.2.0.RELEASE] at org.springframework.cloud.dataflow.registry.support.AppResourceCommon.getResource (AppResour ceCommon. java: 167) ~ [spring-cloud-dataflow-registry-2.4.0.RELEASE.jar! /: 2.4.0.RELEASE] по адресу org.springframework.cloud.dataflow.registry.service.DefaultAppRegistryService.getAppResource (DefaultAppRegistryService. java: 266) ~ [spring-cloud-dataflow-registry-2.4.0.RELEASE.jar! /: 2.4.0.RELEASE] в org.springframework.cloud.dataflow.registry.service.DefaultAppRegistryService $ $ FastClassBySpringCGLIB $$ a8bae4.invoke () ~ [spring-cloud-dataflow-registry-2.4.0.RELEASE.jar! /: 2.4.0.RELEASE] в org.springframework.cglib.proxy.MethodProxy.invoke (MethodProxy. java: 218) ~ [spring-core-5.2.3.RELEASE.jar! /: 5.2.3.RELEASE] в org.springframework.aop.framework.CglibAopProxy $ CglibMethodInvocation.invokeJoinpoint (CglibAopProxy. java: 769 * ) ~ [spring-aop-5.2.3.RELEASE.jar! /: 5.2.3.RELEASE] в org.springframework.aop.framework.ReflectiveMethodInvocation.proceed (ReflectiveMethodInvocation. java: 163) ~ [spring-aop- 5.2.3.RELEASE.jar! /: 5.2.3.RELEASE] в org.springframework.aop.framework.CglibAopProxy $ CglibMethodInvocati on.proceed (CglibAopProxy. java: 747) ~ [spring-aop-5.2.3.RELEASE.jar! /: 5.2.3.RELEASE] в org.springframework.transaction.interceptor.TransactionAspectSupport.invokeWithinTransaction (TransactionAspectSppu 1021 *: 366) ~ [spring-tx-5.2.3.RELEASE.jar! /: 5.2.3.RELEASE] в org.springframework.transaction.interceptor.TransactionInterceptor.invoke (TransactionInterceptor. java: 99) ~ [ spring-tx-5.2.3.RELEASE.jar! /: 5.2.3.RELEASE] в org.springframework.aop.framework.ReflectiveMethodInvocation.proceed (ReflectiveMethodInvocation. java: 186) ~ [spring-aop-5.2.3 .RELEASE.jar! /: 5.2.3.RELEASE] at org.springframework.aop.framework.CglibAopProxy $ CglibMethodInvocation.proceed (CglibAopProxy. java: 747) ~ [spring-aop-5.2.3.RELEASE.jar /:5.2.3.RELEASE] at org.springframework.aop.framework.CglibAopProxy $ DynamicAdvisedInterceptor.intercept (CglibAopProxy. java: 689) ~ [spring-aop-5.2.3.RELEASE.jar! /: 5.2.3 .RELEASE] at org.springframework.cloud.dataflow.registry.service.DefaultAppRegistryService $$ EnhancerBySpringCGLI B $$ 2e83e4f6.getAppResource () ~ [spring-cloud-dataflow-registry-2.4.0.RELEASE.jar! /: 2.4.0.RELEASE] в org.springframework.cloud.dataflow.server.service.impl.DefaultSchedulerService .getTaskLauncherResource (DefaultSchedulerService. java: 423) ~ [spring-cloud-dataflow-server-core-2.4.0.RELEASE.jar! /: 2.4.0.RELEASE] по адресу org.springframework.cloud.dataflow.server. service.impl.DefaultSchedulerService.schedule (DefaultSchedulerService. java: 211) ~ [spring-cloud-dataflow-server-core-2.4.0.RELEASE.jar! /: 2.4.0.RELEASE] в org.springframework.cloud .dataflow.server.controller.TaskSchedulerController.save (TaskSchedulerController. java: 154) ~ [spring-cloud-dataflow-server-core-2.4.0.RELEASE.jar! /: 2.4.0.RELEASE] на солнце. refle.NativeMethodAccessorImpl.invoke0 (собственный метод) ~ [na: 1.8.0_232] at sun.reflect.NativeMethodAccessorImpl.invoke (NativeMethodAccessorImpl. java: 62) ~ [na: 1.8.0_232] at sun.reflect.DelegatingMethodAccessorImpl.invoke (DelegatingMethodAccessorImpl ._2: 43): * 1030: java в java .lang.reflect.Method.invoke (Метод. java: 498) ~ [na: 1.8.0_232] в org.springframework.web.method.support.InvocableHandlerMethod.doInvoke (InvocableHandlerMethod. * 1033: 190) ~ [spring-web-5.2.3.RELEASE.jar! /: 5.2.3.RELEASE] в org.springframework.web.method.support.InvocableHandlerMethod.invokeForRequest (InvocableHandlerMethod. java: 138) ~ [spring -web-5.2.3. spring-web mvc -5.2.3.RELEASE.jar! /: 5.2.3.RELEASE] в org.springframework.web.servlet. mvc .method.annotation.RequestMappingHandlerAdapter.invokeHandlerMethod (RequestMappingHandlerAdapter. 888) ~ [spring-web mvc -5.2.3.RELEASE.jar! /: 5.2.3.REL EASE] at org.springframework.web.servlet. mvc .method.annotation.RequestMappingHandlerAdapter.handleInternal (RequestMappingHandlerAdapter. java: 793) ~ [spring-web mvc -5.2.3.RELEASE.jar! /: 5.2.3.RELEASE] at org.springframework.web.servlet. mvc .method.AbstractHandlerMethodAdapter.handle (AbstractHandlerMethodAdapter. java: 87) ~ [spring-web mvc -5.2.3.RELEASE.jar! /:5.2.3.RELEASE] at org.springframework.web.servlet.DispatcherServlet.doDispatch (DispatcherServlet. java: 1040) ~ [spring-web mvc -5.2.3.RELEASE.jar! /: 5.2. 3.RELEASE] at org.springframework.web.servlet.DispatcherServlet.doService (DispatcherServlet. java: 943) ~ [spring-web mvc -5.2.3.RELEASE.jar! /: 5.2.3.RELEASE] в org.springframework.web.servlet.FrameworkServlet.processRequest (FrameworkServlet. java: 1006) [spring-web mvc -5.2.3.RELEASE.jar! /: 5.2.3.RELEASE] в org.springframework. web.servlet.FrameworkServlet.doPost (FrameworkServlet. java: 909) [spring-web mvc -5.2.3.RELEASE.jar! /: 5.2.3.RELEASE] по адресу javax.servlet.http.HttpSer vlet.service (HttpServlet. java: 660) [tomcat-embed-core-9.0.30.jar! /: 9.0.30] на org.springframework.web.servlet.FrameworkServlet.service (FrameworkServlet. java: 883) [spring-web mvc -5.2.3.RELEASE.jar! /: 5.2.3.RELEASE] по адресу javax.servlet.http.HttpServlet.service (HttpServlet. java: 741) [tomcat-embed- core-9.0.30.jar! /: 9.0.30] at org. apache .catalina.core.ApplicationFilterChain.internalDoFilter (ApplicationFilterChain. java: 231) [tomcat-embed-core-9.0.30.jar! /:9.0.30] at org. apache .catalina.core.ApplicationFilterChain.doFilter (ApplicationFilterChain. java: 166) [tomcat-embed-core-9.0.30.jar! /: 9.0.30] в org . apache .tomcat.websocket.server.WsFilter.doFilter (WsFilter. java: 53) [tomcat-embed-websocket-9.0.30.jar! /: 9.0.30] в орг. apache .catalina .core.ApplicationFilterChain.internalDoFilter (ApplicationFilterChain. java: 193) [tomcat-embed-core-9.0.30.jar! /: 9.0.30] в орг. apache .catalina.core.ApplicationFilterChain.doFilter (ApplicationFilterChater. . java: 166) [tomcat-embed-core-9.0.30.jar! /: 9.0.30 ] в org.springframework.web.filter.ForwardedHeaderFilter.doFilterInternal (ForwardedHeaderFilter. java: 158) [spring-web-5.2.3.RELEASE.jar! /: 5.2.3.RELEASE] в org.springframework.web. filter.OncePerRequestFilter.doFilter (OncePerRequestFilter. java: 119) [spring-web-5.2.3.RELEASE.jar! /: 5.2.3.RELEASE] в орг. apache .catalina.core.ApplicationFilterChain.internalDoFilter ( ApplicationFilterChain. java: 193) [tomcat-embed-core-9.0.30.jar! /: 9.0.30] в org. apache .catalina.core.ApplicationFilterChain.doFilter (ApplicationFilterChain. java: 166) [tomcat-embed-core-9.0.30.jar! /: 9.0.30] на org.springframework.web.filter.RequestContextFilter.doFilterInternal (RequestContextFilter. java: 100) [spring-web-5.2.3.RELEASE .jar! /: 5.2.3.RELEASE] at org.springframework.web.filter.OncePerRequestFilter.doFilter (OncePerRequestFilter. java: 119) [spring-web-5.2.3.RELEASE.jar! /: 5.2.3.RELEASE] в орг. apache .catalina.core.ApplicationFilterChain.internalDoFilter (ApplicationFilterChain. java: 193) [tomcat-embed-core-9.0.30.jar! /: 9.0.30] в орг. apache .catalina.core.ApplicationFilterChain.doFilter (ApplicationFilterChain. java: 166) [tomcat-embed-core-9.0 .30.jar! /: 9.0.30] at org.springframework.web.filter.FormContentFilter.doFilterInternal (FormContentFilter. java: 93) [spring-web-5.2.3.RELEASE.jar! /: 5.2.3 .RELEASE] at org.springframework.web.filter.OncePerRequestFilter.doFilter (OncePerRequestFilter. java: 119) [spring-web-5.2.3.RELEASE.jar! /: 5.2.3.RELEASE] в org. apache .catalina.core.ApplicationFilterChain.internalDoFilter (ApplicationFilterChain. java: 193) [tomcat-embed-core-9.0.30.jar! /: 9.0.30] в орг. apache .catalina.core.ApplicationFilterChain. doFilter (ApplicationFilterChain. java: 166) [tomcat-embed-core-9.0.30.jar! /: 9.0.30] по адресу org.springframework.boot.actuate.metrics.web.servlet.WebMvcMetricsFilter.doFilterInternal (веб-сайт) MvcMetricsFilter. java: 108) [spring-boot-activator-2.2.4.RELEASE.jar! /: 2.2.4.RELEASE] в org.springframework.web.filter.OncePerRequestFilter.doFilter (OncePerRequestFilter. java: 119) [spring-web-5.2.3.RELEASE.jar! /: 5.2.3.RELEASE] в орг. apache .catalina.core.ApplicationFilterChain.internalDoFilter (ApplicationFilterChain. java: 193) [tomcat-embed -core-9.0.30.jar! /: 9.0.30] в орг. apache .catalina.core.ApplicationFilterChain.doFilter (ApplicationFilterChain. java: 166) [tomcat-embed-core-9.0.30.jar ! /: 9.0.30] at org.springframework.web.filter.CharacterEncodingFilter.doFilterInternal (CharacterEncodingFilter. java: 201) [spring-web-5.2.3.RELEASE.jar! /: 5.2.3.RELEASE] в org.springframework.web.filter.OncePerRequestFilter.doFilter (OncePerRequestFilter. java: 119) [spring-web-5.2.3.RELEASE.jar! /: 5.2.3.RELEASE] в орг. apache .catalina. core.ApplicationFilterChain.internalDoFilter (ApplicationFilterChain. java: 193) [tomcat-embed-core-9.0.30.jar! /: 9.0.30] в орг. apache .catalina.core.ApplicationFilterCh ain.doFilter (ApplicationFilterChain. java: 166) [tomcat-embed-core-9.0.30.jar! /: 9.0.30] в org. apache .catalina.core.StandardWrapperValve.invoke (StandardWrapperValve. java: 202) [tomcat-embed-core-9.0.30.jar! /: 9.0.30] в орг. apache .catalina.core.StandardContextValve.invoke (StandardContextValve. java: 96) [tomcat-embed -core-9.0.30.jar! /: 9.0.30] в орг. apache .catalina.authenticator.AuthenticatorBase.invoke (AuthenticatorBase. java: 541) [tomcat-embed-core-9.0.30.jar ! /: 9.0.30] at org. apache .catalina.core.StandardHostValve.invoke (StandardHostValve. java: 139) [tomcat-embed-core-9.0.30.jar! /: 9.0.30] в org. apache .catalina.valves.ErrorReportValve.invoke (ErrorReportValve. java: 92) [tomcat-embed-core-9.0.30.jar! /: 9.0.30] в org. apache .catalina. core.StandardEngineValve.invoke (StandardEngineValve. java: 74) [tomcat-embed-core-9.0.30.jar! /: 9.0.30] в орг. apache .catalina.valves.RemoteIpValve.invoke (RemoteIpValve. java: 747) [tomcat-embed-core-9.0.30.jar! /: 9.0.30] в орг. apache .catalina.connector.Co yoteAdapter.service (CoyoteAdapter. java: 343) [tomcat-embed-core-9.0.30.jar! /: 9.0.30] в орг. apache .coyote.http11.Http11Processor.service (Http11Processor. java: 367) [tomcat-embed-core-9.0.30.jar! /: 9.0.30] в орг. apache .coyote.AbstractProcessorLight.process (AbstractProcessorLight. java: 65) [tomcat-embed-core -9.0.30.jar! /: 9.0.30] at org. apache .coyote.AbstractProtocol $ ConnectionHandler.process (AbstractProtocol. java: 860) [tomcat-embed-core-9.0.30.jar! / : 9.0.30] at org. apache .tomcat.util. net .NioEndpoint $ SocketProcessor.doRun (NioEndpoint. java: 1598) [tomcat-embed-core-9.0.30.jar! /: 9.0 .30] at org. apache .tomcat.util. net .SocketProcessorBase.run (SocketProcessorBase. java: 49) [tomcat-embed-core-9.0.30.jar! /: 9.0.30] в java .util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor. java: 1149) [na: 1.8.0_232] в java .util.concurrent.ThreadPoolExecutor $ Worker.run (ThreadPoolExecutor. java: 624) [na: 1.8.0_232] в орг. apache .tomcat.util.threads.TaskThread $ WrappingRunnable.run (TaskThread . java: 61) [tomcat-embed-core-9.0.30.jar! /: 9.0.30] в java .lang.Thread.run (Thread. java: 748) [na: 1,8. 0_232]

Я не знаю, что это значит, я новичок ie в потоке данных. Я не понимаю, почему он пытается использовать Maven вместо Kubernetes и почему я получаю эту ошибку. Может ли кто-нибудь дать мне более подробное объяснение?

Кстати, я регистрирую приложения как docker контейнеры.

1 Ответ

1 голос
/ 16 марта 2020

На основе приведенного выше журнала он пытается загрузить ресурс maven при запуске запланированного задания. Это потому, что вы зарегистрировали свои приложения задач как ресурсы maven вместо docker изображений. Вам необходимо зарегистрировать docker образов приложений задач в среде Kubernetes.

После выпуска 2.3.x SCDF запускает запланированные задачи через приложение задач под названием scheduler-task-launcher. По умолчанию он настроен на использование ресурса maven, и вам нужно изменить его на использование docker изображения. Чтобы изменить, вы можете установить для свойства: spring.cloud.dataflow.task.scheduler-task-launcher-url значение docker: // springcloud / springcloud / cloud-cloud-dataflow-scheduler-task-launcher: 2.4.0.RELEASE

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...