CloudFoundry上的Spring Cloud数据流 [英] Spring Cloud data Flow on CloudFoundry

查看:65
本文介绍了CloudFoundry上的Spring Cloud数据流的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!

问题描述

我已将Spring Cloud Data Flow Server的1.2.2版本推入PCF(Pivotal Cloud Foundry).我使用maven注册了一个应用程序,但是使用Flo UI从该应用程序创建任务失败,并出现以下异常跟踪,它们有点难以理解,但是在尝试连接到

I have pushed the 1.2.2 version of spring cloud data flow server into PCF (Pivotal Cloud Foundry). I registered an app using maven but creating a task from the App using Flo UI fails with following exception trace, they are a bit unintelligible but looks like there is a ConnectException when trying to connect to default config server at http://localhost:8888. I do not need a config server for now. How do I get rid of this and get on with life? -

通过这种方式,我试图为我的组织创建一个基于PCF微服务的按需解析器.

By the way I am trying to create an on-demand PCF microservice based parser for my Org.

现在我可以创建一个任务,但是当我尝试启动该任务时得到了此信息-CF-UnprocessableEntity(10008):请求在语义上无效:任务必须具有一个Droplet.指定液滴或将当前液滴分配给应用.

Now I am able to create a task but I get this when I try to launch the task - CF-UnprocessableEntity(10008): The request is semantically invalid: Task must have a droplet. Specify droplet or assign current droplet to app.

以下是日志-

2017-07-13T15:20:12.575 + 05:30 [RTR/0] [OUT] data-flow-server.apps.titan.lab.emc.com-[2017-07-13T09:50:12.544+0000]"GET/tasks/definitions?page = 0& size = 10& sort = DEFINITION_NAME,DEFINITION,ASC HTTP/1.0" 200 0 682"

2017-07-13T15:20:12.575+05:30 [RTR/0] [OUT] data-flow-server.apps.titan.lab.emc.com - [2017-07-13T09:50:12.544+0000] "GET /tasks/definitions?page=0&size=10&sort=DEFINITION_NAME,DEFINITION,ASC HTTP/1.0" 200 0 682 "https://data-flow-server.apps.titan.lab.emc.com/dashboard/index.html" "Mozilla/5.0 (Windows NT 6.1; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/59.0.3071.115 Safari/537.36" "172.16.7.103:57574" "172.16.4.167:62442" x_forwarded_for:"-" x_forwarded_proto:"https" vcap_request_id:"3525c07a-ccf4-48b9-4d90-0c40658fa696" response_time:0.030533986 app_id:"405aad06-0bda-4b73-b0c4-b8d03a131fa5" app_index:"0" x_b3_traceid:"deed52aa152480b0" x_b3_spanid:"deed52aa152480b0" x_b3_parentspanid:"-" 2017-07-13T15:20:14.133+05:30 [APP/PROC/WEB/0] [OUT] org.cloudfoundry.client.v3.ClientV3Exception: CF-UnprocessableEntity(10008): The request is semantically invalid: Task must have a droplet. Specify droplet or assign current droplet to app. 2017-07-13T15:20:14.133+05:30 [APP/PROC/WEB/0] [OUT] 2017-07-13 09:50:14.132 ERROR 15 --- [ry-client-nio-1] s.c.CloudFoundry2630AndLaterTaskLauncher : Task sampleDataFlowTask launch failed 2017-07-13T15:20:14.133+05:30 [APP/PROC/WEB/0] [OUT] at org.cloudfoundry.reactor.util.ErrorPayloadMapper.lambda$null$3(ErrorPayloadMapper.java:65) ~[cloudfoundry-client-reactor-2.14.0.RELEASE.jar!/:2.14.0.RELEASE] 2017-07-13T15:20:14.133+05:30 [APP/PROC/WEB/0] [OUT] at org.cloudfoundry.reactor.util.ErrorPayloadMapper.lambda$null$10(ErrorPayloadMapper.java:108) ~[cloudfoundry-client-reactor-2.14.0.RELEASE.jar!/:2.14.0.RELEASE] 2017-07-13T15:20:14.133+05:30 [APP/PROC/WEB/0] [OUT] at reactor.core.publisher.MonoThenMap$ThenMapMain.onNext(MonoThenMap.java:120) ~[reactor-core-3.0.7.RELEASE.jar!/:3.0.7.RELEASE] 2017-07-13T15:20:14.133+05:30 [APP/PROC/WEB/0] [OUT] at reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onNext(FluxSwitchIfEmpty.java:67) ~[reactor-core-3.0.7.RELEASE.jar!/:3.0.7.RELEASE] 2017-07-13T15:20:14.134+05:30 [APP/PROC/WEB/0] [OUT] at reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:108) ~[reactor-core-3.0.7.RELEASE.jar!/:3.0.7.RELEASE] 2017-07-13T15:20:14.134+05:30 [APP/PROC/WEB/0] [OUT] at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:115) ~[reactor-core-3.0.7.RELEASE.jar!/:3.0.7.RELEASE] 2017-07-13T15:20:14.134+05:30 [APP/PROC/WEB/0] [OUT] at reactor.core.publisher.FluxUsing$UsingFuseableSubscriber.onNext(FluxUsing.java:351) ~[reactor-core-3.0.7.RELEASE.jar!/:3.0.7.RELEASE] 2017-07-13T15:20:14.134+05:30 [APP/PROC/WEB/0] [OUT] at reactor.core.publisher.FluxFilterFuseable$FilterFuseableSubscriber.onNext(FluxFilterFuseable.java:103) ~[reactor-core-3.0.7.RELEASE.jar!/:3.0.7.RELEASE] 2017-07-13T15:20:14.134+05:30 [APP/PROC/WEB/0] [OUT] at reactor.core.publisher.FluxPeekFuseable$PeekFuseableConditionalSubscriber.onNext(FluxPeekFuseable.java:428) ~[reactor-core-3.0.7.RELEASE.jar!/:3.0.7.RELEASE] 2017-07-13T15:20:14.134+05:30 [APP/PROC/WEB/0] [OUT] at reactor.ipc.netty.channel.FluxReceive.drainReceiver(FluxReceive.java:198) ~[reactor-netty-0.6.4.RELEASE.jar!/:0.6.4.RELEASE] 2017-07-13T15:20:14.134+05:30 [APP/PROC/WEB/0] [OUT] at reactor.ipc.netty.channel.FluxReceive.onInboundComplete(FluxReceive.java:338) ~[reactor-netty-0.6.4.RELEASE.jar!/:0.6.4.RELEASE] 2017-07-13T15:20:14.134+05:30 [APP/PROC/WEB/0] [OUT] at reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:962) ~[reactor-core-3.0.7.RELEASE.jar!/:3.0.7.RELEASE] 2017-07-13T15:20:14.134+05:30 [APP/PROC/WEB/0] [OUT] at reactor.core.publisher.MonoReduceSeed$ReduceSeedSubscriber.onComplete(MonoReduceSeed.java:150) ~[reactor-core-3.0.7.RELEASE.jar!/:3.0.7.RELEASE] 2017-07-13T15:20:14.134+05:30 [APP/PROC/WEB/0] [OUT] at reactor.core.publisher.FluxMap$MapSubscriber.onComplete(FluxMap.java:130) ~[reactor-core-3.0.7.RELEASE.jar!/:3.0.7.RELEASE] 2017-07-13T15:20:14.134+05:30 [APP/PROC/WEB/0] [OUT] at reactor.ipc.netty.channel.FluxReceive.terminateReceiver(FluxReceive.java:375) ~[reactor-netty-0.6.4.RELEASE.jar!/:0.6.4.RELEASE] 2017-07-13T15:20:14.134+05:30 [APP/PROC/WEB/0] [OUT] at reactor.ipc.netty.channel.ChannelOperations.onInboundComplete(ChannelOperations.java:343) ~[reactor-netty-0.6.4.RELEASE.jar!/:0.6.4.RELEASE] 2017-07-13T15:20:14.134+05:30 [APP/PROC/WEB/0] [OUT] at reactor.ipc.netty.channel.ChannelOperations.onHandlerTerminate(ChannelOperations.java:419) ~[reactor-netty-0.6.4.RELEASE.jar!/:0.6.4.RELEASE] 2017-07-13T15:20:14.134+05:30 [APP/PROC/WEB/0] [OUT] at reactor.ipc.netty.http.client.HttpClientOperations.onInboundNext(HttpClientOperations.java:566) ~[reactor-netty-0.6.4.RELEASE.jar!/:0.6.4.RELEASE] 2017-07-13T15:20:14.134+05:30 [APP/PROC/WEB/0] [OUT] at reactor.ipc.netty.channel.ChannelOperationsHandler.channelRead(ChannelOperationsHandler.java:125) ~[reactor-netty-0.6.4.RELEASE.jar!/:0.6.4.RELEASE] 2017-07-13T15:20:14.134+05:30 [APP/PROC/WEB/0] [OUT] at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) ~[netty-transport-4.1.9.Final.jar!/:4.1.9.Final] 2017-07-13T15:20:14.134+05:30 [APP/PROC/WEB/0] [OUT] at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) ~[netty-transport-4.1.9.Final.jar!/:4.1.9.Final] 2017-07-13T15:20:14.134+05:30 [APP/PROC/WEB/0] [OUT] at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) ~[netty-transport-4.1.9.Final.jar!/:4.1.9.Final] 2017-07-13T15:20:14.134+05:30 [APP/PROC/WEB/0] [OUT] at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:293) ~[netty-codec-4.1.9.Final.jar!/:4.1.9.Final] 2017-07-13T15:20:14.134+05:30 [APP/PROC/WEB/0] [OUT] at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:267) ~[netty-codec-4.1.9.Final.jar!/:4.1.9.Final] 2017-07-13T15:20:14.134+05:30 [APP/PROC/WEB/0] [OUT] at io.netty.handler.ssl.SslHandler.unwrap(SslHandler.java:1240) ~[netty-handler-4.1.9.Final.jar!/:4.1.9.Final] 2017-07-13T15:20:14.134+05:30 [APP/PROC/WEB/0] [OUT] at io.netty.handler.ssl.SslHandler.decode(SslHandler.java:1041) ~[netty-handler-4.1.9.Final.jar!/:4.1.9.Final] 2017-07-13T15:20:14.134+05:30 [APP/PROC/WEB/0] [OUT] at io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:411) ~[netty-codec-4.1.9.Final.jar!/:4.1.9.Final] 2017-07-13T15:20:14.134+05:30 [APP/PROC/WEB/0] [OUT] at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:248) ~[netty-codec-4.1.9.Final.jar!/:4.1.9.Final] 2017-07-13T15:20:14.134+05:30 [APP/PROC/WEB/0] [OUT] at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1334) ~[netty-transport-4.1.9.Final.jar!/:4.1.9.Final] 2017-07-13T15:20:14.134+05:30 [APP/PROC/WEB/0] [OUT] at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:926) ~[netty-transport-4.1.9.Final.jar!/:4.1.9.Final] 2017-07-13T15:20:14.134+05:30 [APP/PROC/WEB/0] [OUT] at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:134) ~[netty-transport-4.1.9.Final.jar!/:4.1.9.Final] 2017-07-13T15:20:14.134+05:30 [APP/PROC/WEB/0] [OUT] at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:624) ~[netty-transport-4.1.9.Final.jar!/:4.1.9.Final] 2017-07-13T15:20:14.134+05:30 [APP/PROC/WEB/0] [OUT] at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:559) ~[netty-transport-4.1.9.Final.jar!/:4.1.9.Final] 2017-07-13T15:20:14.134+05:30 [APP/PROC/WEB/0] [OUT] at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:476) ~[netty-transport-4.1.9.Final.jar!/:4.1.9.Final] 2017-07-13T15:20:14.134+05:30 [APP/PROC/WEB/0] [OUT] at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:438) ~[netty-transport-4.1.9.Final.jar!/:4.1.9.Final] 2017-07-13T15:20:14.134+05:30 [APP/PROC/WEB/0] [OUT] at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:858) ~[netty-common-4.1.9.Final.jar!/:4.1.9.Final] 2017-07-13T15:20:14.134+05:30 [APP/PROC/WEB/0] [OUT] at java.lang.Thread.run(Thread.java:748) ~[na:1.8.0_131] 2017-07-13T15:20:14.134+05:30 [APP/PROC/WEB/0] [OUT] Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException: 2017-07-13T15:20:14.134+05:30 [APP/PROC/WEB/0] [OUT] Assembly trace from producer [reactor.core.publisher.MonoPeek] : 2017-07-13T15:20:14.134+05:30 [APP/PROC/WEB/0] [OUT] reactor.core.publisher.Mono.checkpoint(Mono.java:1400) 2017-07-13T15:20:14.134+05:30 [APP/PROC/WEB/0] [OUT] org.cloudfoundry.reactor.client.v3.tasks.ReactorTasks.create(ReactorTasks.java:58) 2017-07-13T15:20:14.134+05:30 [APP/PROC/WEB/0] [OUT] org.springframework.cloud.deployer.spi.cloudfoundry.CloudFoundry2630AndLaterTaskLauncher.requestCreateTask(CloudFoundry2630AndLaterTaskLauncher.java:170) 2017-07-13T15:20:14.134+05:30 [APP/PROC/WEB/0] [OUT] org.springframework.cloud.deployer.spi.cloudfoundry.CloudFoundry2630AndLaterTaskLauncher.launchTask(CloudFoundry2630AndLaterTaskLauncher.java:144) 2017-07-13T15:20:14.134+05:30 [APP/PROC/WEB/0] [OUT] org.springframework.cloud.deployer.spi.cloudfoundry.CloudFoundry2630AndLaterTaskLauncher.lambda$launch$0(CloudFoundry2630AndLaterTaskLauncher.java:91) 2017-07-13T15:20:14.134+05:30 [APP/PROC/WEB/0] [OUT] reactor.core.publisher.MonoThenMap$ThenMapMain.onNext(MonoThenMap.java:120) 2017-07-13T15:20:14.134+05:30 [APP/PROC/WEB/0] [OUT] reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:962) 2017-07-13T15:20:14.134+05:30 [APP/PROC/WEB/0] [OUT] reactor.core.publisher.MonoThenMap$ThenMapMain$ThenMapInner.onNext(MonoThenMap.java:237) 2017-07-13T15:20:14.134+05:30 [APP/PROC/WEB/0] [OUT] reactor.core.publisher.FluxPeek$PeekSubscriber.onNext(FluxPeek.java:173) 2017-07-13T15:20:14.134+05:30 [APP/PROC/WEB/0] [OUT] reactor.core.publisher.MonoNext$NextSubscriber.onNext(MonoNext.java:76) 2017-07-13T15:20:14.134+05:30 [APP/PROC/WEB/0] [OUT] reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:108) 2017-07-13T15:20:14.134+05:30 [APP/PROC/WEB/0] [OUT] reactor.core.publisher.MonoFlatMap$FlatMapInner.onNext(MonoFlatMap.java:235) 2017-07-13T15:20:14.134+05:30 [APP/PROC/WEB/0] [OUT] reactor.ipc.netty.channel.FluxReceive.drainReceiver(FluxReceive.java:207) 2017-07-13T15:20:14.134+05:30 [APP/PROC/WEB/0] [OUT] reactor.ipc.netty.channel.FluxReceive.onInboundNext(FluxReceive.java:322) 2017-07-13T15:20:14.134+05:30 [APP/PROC/WEB/0] [OUT] reactor.ipc.netty.channel.ChannelOperations.onInboundNext(ChannelOperations.java:316) 2017-07-13T15:20:14.135+05:30 [APP/PROC/WEB/0] [OUT] reactor.ipc.netty.http.client.HttpClientOperations.onInboundNext(HttpClientOperations.java:581) 2017-07-13T15:20:14.135+05:30 [APP/PROC/WEB/0] [OUT] reactor.ipc.netty.channel.ChannelOperationsHandler.channelRead(ChannelOperationsHandler.java:125) 2017-07-13T15:20:14.135+05:30 [APP/PROC/WEB/0] [OUT] io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) 2017-07-13T15:20:14.135+05:30 [APP/PROC/WEB/0] [OUT] io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) 2017-07-13T15:20:14.135+05:30 [APP/PROC/WEB/0] [OUT] io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) 2017-07-13T15:20:14.135+05:30 [APP/PROC/WEB/0] [OUT] io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:293) 2017-07-13T15:20:14.135+05:30 [APP/PROC/WEB/0] [OUT] io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:267) 2017-07-13T15:20:14.135+05:30 [APP/PROC/WEB/0] [OUT] reactor.ipc.netty.http.HttpOperations.lambda$static$3(HttpOperations.java:261) 2017-07-13T15:20:14.135+05:30 [APP/PROC/WEB/0] [OUT] reactor.ipc.netty.ReactorNetty$ExtractorHandler.channelRead(ReactorNetty.java:328) 2017-07-13T15:20:14.135+05:30 [APP/PROC/WEB/0] [OUT] io.netty.handler.ssl.SslHandler.unwrap(SslHandler.java:1240) 2017-07-13T15:20:14.135+05:30 [APP/PROC/WEB/0] [OUT] io.netty.handler.ssl.SslHandler.decode(SslHandler.java:1041) 2017-07-13T15:20:14.135+05:30 [APP/PROC/WEB/0] [OUT] io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:411) 2017-07-13T15:20:14.135+05:30 [APP/PROC/WEB/0] [OUT] io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:248) 2017-07-13T15:20:14.135+05:30 [APP/PROC/WEB/0] [OUT] io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1334) 2017-07-13T15:20:14.135+05:30 [APP/PROC/WEB/0] [OUT] io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:926) 2017-07-13T15:20:14.135+05:30 [APP/PROC/WEB/0] [OUT] io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:134) 2017-07-13T15:20:14.135+05:30 [APP/PROC/WEB/0] [OUT] io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:624) 2017-07-13T15:20:14.135+05:30 [APP/PROC/WEB/0] [OUT] io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:559) 2017-07-13T15:20:14.135+05:30 [APP/PROC/WEB/0] [OUT] io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:476) 2017-07-13T15:20:14.135+05:30 [APP/PROC/WEB/0] [OUT] io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:438) 2017-07-13T15:20:14.135+05:30 [APP/PROC/WEB/0] [OUT] io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:858) 2017-07-13T15:20:14.135+05:30 [APP/PROC/WEB/0] [OUT] Error has been observed by the following operator(s): 2017-07-13T15:20:14.135+05:30 [APP/PROC/WEB/0] [OUT] |_ Mono.checkpoint(ReactorTasks.java:58) 2017-07-13T15:20:14.145+05:30 [APP/PROC/WEB/0] [OUT] at org.cloudfoundry.reactor.util.ErrorPayloadMapper.lambda$null$10(ErrorPayloadMapper.java:108) ~[cloudfoundry-client-reactor-2.14.0.RELEASE.jar!/:2.14.0.RELEASE] 2017-07-13T15:20:14.145+05:30 [APP/PROC/WEB/0] [OUT] at reactor.core.publisher.MonoThenMap$ThenMapMain.onNext(MonoThenMap.java:120) ~[reactor-core-3.0.7.RELEASE.jar!/:3.0.7.RELEASE] 2017-07-13T15:20:14.145+05:30 [APP/PROC/WEB/0] [OUT] at reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onNext(FluxSwitchIfEmpty.java:67) ~[reactor-core-3.0.7.RELEASE.jar!/:3.0.7.RELEASE] 2017-07-13T15:20:14.145+05:30 [APP/PROC/WEB/0] [OUT] 2017-07-13 09:50:14.143 ERROR 15 --- [nio-8080-exec-2] o.s.c.d.s.c.RestControllerAdvice : Caught exception while handling a request 2017-07-13T15:20:14.145+05:30 [APP/PROC/WEB/0] [OUT] org.cloudfoundry.client.v3.ClientV3Exception: CF-UnprocessableEntity(10008): The request is semantically invalid: Task must have a droplet. Specify droplet or assign current droplet to app. 2017-07-13T15:20:14.145+05:30 [APP/PROC/WEB/0] [OUT] at org.cloudfoundry.reactor.util.ErrorPayloadMapper.lambda$null$3(ErrorPayloadMapper.java:65) ~[cloudfoundry-client-reactor-2.14.0.RELEASE.jar!/:2.14.0.RELEASE] 2017-07-13T15:20:14.145+05:30 [APP/PROC/WEB/0] [OUT] at reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:108) ~[reactor-core-3.0.7.RELEASE.jar!/:3.0.7.RELEASE] 2017-07-13T15:20:14.145+05:30 [APP/PROC/WEB/0] [OUT] at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:115) ~[reactor-core-3.0.7.RELEASE.jar!/:3.0.7.RELEASE] 2017-07-13T15:20:14.145+05:30 [APP/PROC/WEB/0] [OUT] at reactor.core.publisher.FluxUsing$UsingFuseableSubscriber.onNext(FluxUsing.java:351) ~[reactor-core-3.0.7.RELEASE.jar!/:3.0.7.RELEASE] 2017-07-13T15:20:14.145+05:30 [APP/PROC/WEB/0] [OUT] at reactor.core.publisher.FluxFilterFuseable$FilterFuseableSubscriber.onNext(FluxFilterFuseable.java:103) ~[reactor-core-3.0.7.RELEASE.jar!/:3.0.7.RELEASE] 2017-07-13T15:20:14.145+05:30 [APP/PROC/WEB/0] [OUT] at reactor.core.publisher.FluxPeekFuseable$PeekFuseableConditionalSubscriber.onNext(FluxPeekFuseable.java:428) ~[reactor-core-3.0.7.RELEASE.jar!/:3.0.7.RELEASE] 2017-07-13T15:20:14.145+05:30 [APP/PROC/WEB/0] [OUT] at reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:962) ~[reactor-core-3.0.7.RELEASE.jar!/:3.0.7.RELEASE] 2017-07-13T15:20:14.145+05:30 [APP/PROC/WEB/0] [OUT] at reactor.core.publisher.MonoReduceSeed$ReduceSeedSubscriber.onComplete(MonoReduceSeed.java:150) ~[reactor-core-3.0.7.RELEASE.jar!/:3.0.7.RELEASE] 2017-07-13T15:20:14.145+05:30 [APP/PROC/WEB/0] [OUT] at reactor.core.publisher.FluxMap$MapSubscriber.onComplete(FluxMap.java:130) ~[reactor-core-3.0.7.RELEASE.jar!/:3.0.7.RELEASE] 2017-07-13T15:20:14.145+05:30 [APP/PROC/WEB/0] [OUT] at reactor.ipc.netty.channel.FluxReceive.terminateReceiver(FluxReceive.java:375) ~[reactor-netty-0.6.4.RELEASE.jar!/:0.6.4.RELEASE] 2017-07-13T15:20:14.145+05:30 [APP/PROC/WEB/0] [OUT] at reactor.ipc.netty.channel.FluxReceive.drainReceiver(FluxReceive.java:198) ~[reactor-netty-0.6.4.RELEASE.jar!/:0.6.4.RELEASE] 2017-07-13T15:20:14.145+05:30 [APP/PROC/WEB/0] [OUT] at reactor.ipc.netty.channel.FluxReceive.onInboundComplete(FluxReceive.java:338) ~[reactor-netty-0.6.4.RELEASE.jar!/:0.6.4.RELEASE] 2017-07-13T15:20:14.145+05:30 [APP/PROC/WEB/0] [OUT] at reactor.ipc.netty.channel.ChannelOperations.onInboundComplete(ChannelOperations.java:343) ~[reactor-netty-0.6.4.RELEASE.jar!/:0.6.4.RELEASE] 2017-07-13T15:20:14.145+05:30 [APP/PROC/WEB/0] [OUT] at reactor.ipc.netty.channel.ChannelOperations.onHandlerTerminate(ChannelOperations.java:419) ~[reactor-netty-0.6.4.RELEASE.jar!/:0.6.4.RELEASE] 2017-07-13T15:20:14.146+05:30 [APP/PROC/WEB/0] [OUT] at reactor.ipc.netty.http.client.HttpClientOperations.onInboundNext(HttpClientOperations.java:566) ~[reactor-netty-0.6.4.RELEASE.jar!/:0.6.4.RELEASE] 2017-07-13T15:20:14.146+05:30 [APP/PROC/WEB/0] [OUT] at reactor.ipc.netty.channel.ChannelOperationsHandler.channelRead(ChannelOperationsHandler.java:125) ~[reactor-netty-0.6.4.RELEASE.jar!/:0.6.4.RELEASE] 2017-07-13T15:20:14.146+05:30 [APP/PROC/WEB/0] [OUT] at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) ~[netty-transport-4.1.9.Final.jar!/:4.1.9.Final] 2017-07-13T15:20:14.146+05:30 [APP/PROC/WEB/0] [OUT] at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) ~[netty-transport-4.1.9.Final.jar!/:4.1.9.Final] 2017-07-13T15:20:14.146+05:30 [APP/PROC/WEB/0] [OUT] at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) ~[netty-transport-4.1.9.Final.jar!/:4.1.9.Final] 2017-07-13T15:20:14.146+05:30 [APP/PROC/WEB/0] [OUT] at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:293) ~[netty-codec-4.1.9.Final.jar!/:4.1.9.Final] 2017-07-13T15:20:14.146+05:30 [APP/PROC/WEB/0] [OUT] at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:267) ~[netty-codec-4.1.9.Final.jar!/:4.1.9.Final] 2017-07-13T15:20:14.146+05:30 [APP/PROC/WEB/0] [OUT] at io.netty.handler.ssl.SslHandler.unwrap(SslHandler.java:1240) ~[netty-handler-4.1.9.Final.jar!/:4.1.9.Final] 2017-07-13T15:20:14.146+05:30 [APP/PROC/WEB/0] [OUT] at io.netty.handler.ssl.SslHandler.decode(SslHandler.java:1041) ~[netty-handler-4.1.9.Final.jar!/:4.1.9.Final] 2017-07-13T15:20:14.146+05:30 [APP/PROC/WEB/0] [OUT] at io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:411) ~[netty-codec-4.1.9.Final.jar!/:4.1.9.Final] 2017-07-13T15:20:14.146+05:30 [APP/PROC/WEB/0] [OUT] at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:248) ~[netty-codec-4.1.9.Final.jar!/:4.1.9.Final] 2017-07-13T15:20:14.146+05:30 [APP/PROC/WEB/0] [OUT] at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1334) ~[netty-transport-4.1.9.Final.jar!/:4.1.9.Final] 2017-07-13T15:20:14.146+05:30 [APP/PROC/WEB/0] [OUT] at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:926) ~[netty-transport-4.1.9.Final.jar!/:4.1.9.Final] 2017-07-13T15:20:14.146+05:30 [APP/PROC/WEB/0] [OUT] at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:134) ~[netty-transport-4.1.9.Final.jar!/:4.1.9.Final] 2017-07-13T15:20:14.146+05:30 [APP/PROC/WEB/0] [OUT] at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:624) ~[netty-transport-4.1.9.Final.jar!/:4.1.9.Final] 2017-07-13T15:20:14.146+05:30 [APP/PROC/WEB/0] [OUT] at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:559) ~[netty-transport-4.1.9.Final.jar!/:4.1.9.Final] 2017-07-13T15:20:14.146+05:30 [APP/PROC/WEB/0] [OUT] at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:476) ~[netty-transport-4.1.9.Final.jar!/:4.1.9.Final] 2017-07-13T15:20:14.146+05:30 [APP/PROC/WEB/0] [OUT] at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:438) ~[netty-transport-4.1.9.Final.jar!/:4.1.9.Final] 2017-07-13T15:20:14.146+05:30 [APP/PROC/WEB/0] [OUT] at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:858) ~[netty-common-4.1.9.Final.jar!/:4.1.9.Final] 2017-07-13T15:20:14.146+05:30 [APP/PROC/WEB/0] [OUT] at java.lang.Thread.run(Thread.java:748) ~[na:1.8.0_131] 2017-07-13T15:20:14.146+05:30 [APP/PROC/WEB/0] [OUT] Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException: 2017-07-13T15:20:14.146+05:30 [APP/PROC/WEB/0] [OUT] Assembly trace from producer [reactor.core.publisher.MonoPeek] : 2017-07-13T15:20:14.146+05:30 [APP/PROC/WEB/0] [OUT] reactor.core.publisher.Mono.checkpoint(Mono.java:1400) 2017-07-13T15:20:14.146+05:30 [APP/PROC/WEB/0] [OUT] org.cloudfoundry.reactor.client.v3.tasks.ReactorTasks.create(ReactorTasks.java:58) 2017-07-13T15:20:14.146+05:30 [APP/PROC/WEB/0] [OUT] org.springframework.cloud.deployer.spi.cloudfoundry.CloudFoundry2630AndLaterTaskLauncher.requestCreateTask(CloudFoundry2630AndLaterTaskLauncher.java:170) 2017-07-13T15:20:14.146+05:30 [APP/PROC/WEB/0] [OUT] org.springframework.cloud.deployer.spi.cloudfoundry.CloudFoundry2630AndLaterTaskLauncher.launchTask(CloudFoundry2630AndLaterTaskLauncher.java:144) 2017-07-13T15:20:14.146+05:30 [APP/PROC/WEB/0] [OUT] org.springframework.cloud.deployer.spi.cloudfoundry.CloudFoundry2630AndLaterTaskLauncher.lambda$launch$0(CloudFoundry2630AndLaterTaskLauncher.java:91) 2017-07-13T15:20:14.146+05:30 [APP/PROC/WEB/0] [OUT] reactor.core.publisher.MonoThenMap$ThenMapMain.onNext(MonoThenMap.java:120) 2017-07-13T15:20:14.146+05:30 [APP/PROC/WEB/0] [OUT] reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:962) 2017-07-13T15:20:14.146+05:30 [APP/PROC/WEB/0] [OUT] reactor.core.publisher.MonoThenMap$ThenMapMain$ThenMapInner.onNext(MonoThenMap.java:237) 2017-07-13T15:20:14.146+05:30 [APP/PROC/WEB/0] [OUT] reactor.core.publisher.FluxPeek$PeekSubscriber.onNext(FluxPeek.java:173) 2017-07-13T15:20:14.146+05:30 [APP/PROC/WEB/0] [OUT] reactor.core.publisher.MonoNext$NextSubscriber.onNext(MonoNext.java:76) 2017-07-13T15:20:14.146+05:30 [APP/PROC/WEB/0] [OUT] reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:108) 2017-07-13T15:20:14.146+05:30 [APP/PROC/WEB/0] [OUT] reactor.core.publisher.MonoFlatMap$FlatMapInner.onNext(MonoFlatMap.java:235) 2017-07-13T15:20:14.146+05:30 [APP/PROC/WEB/0] [OUT] reactor.ipc.netty.channel.FluxReceive.drainReceiver(FluxReceive.java:207) 2017-07-13T15:20:14.146+05:30 [APP/PROC/WEB/0] [OUT] reactor.ipc.netty.channel.FluxReceive.onInboundNext(FluxReceive.java:322) 2017-07-13T15:20:14.146+05:30 [APP/PROC/WEB/0] [OUT] reactor.ipc.netty.channel.ChannelOperations.onInboundNext(ChannelOperations.java:316) 2017-07-13T15:20:14.146+05:30 [APP/PROC/WEB/0] [OUT] reactor.ipc.netty.http.client.HttpClientOperations.onInboundNext(HttpClientOperations.java:581) 2017-07-13T15:20:14.146+05:30 [APP/PROC/WEB/0] [OUT] reactor.ipc.netty.channel.ChannelOperationsHandler.channelRead(ChannelOperationsHandler.java:125) 2017-07-13T15:20:14.146+05:30 [APP/PROC/WEB/0] [OUT] io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) 2017-07-13T15:20:14.146+05:30 [APP/PROC/WEB/0] [OUT] io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) 2017-07-13T15:20:14.146+05:30 [APP/PROC/WEB/0] [OUT] io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) 2017-07-13T15:20:14.146+05:30 [APP/PROC/WEB/0] [OUT] io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:293) 2017-07-13T15:20:14.146+05:30 [APP/PROC/WEB/0] [OUT] io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:267) 2017-07-13T15:20:14.146+05:30 [APP/PROC/WEB/0] [OUT] reactor.ipc.netty.http.HttpOperations.lambda$static$3(HttpOperations.java:261) 2017-07-13T15:20:14.146+05:30 [APP/PROC/WEB/0] [OUT] reactor.ipc.netty.ReactorNetty$ExtractorHandler.channelRead(ReactorNetty.java:328) 2017-07-13T15:20:14.147+05:30 [APP/PROC/WEB/0] [OUT] io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) 2017-07-13T15:20:14.147+05:30 [APP/PROC/WEB/0] [OUT] io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) 2017-07-13T15:20:14.147+05:30 [APP/PROC/WEB/0] [OUT] io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:293) 2017-07-13T15:20:14.147+05:30 [APP/PROC/WEB/0] [OUT] io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:267) 2017-07-13T15:20:14.147+05:30 [APP/PROC/WEB/0] [OUT] io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) 2017-07-13T15:20:14.147+05:30 [APP/PROC/WEB/0] [OUT] io.netty.handler.ssl.SslHandler.unwrap(SslHandler.java:1240) 2017-07-13T15:20:14.147+05:30 [APP/PROC/WEB/0] [OUT] io.netty.handler.ssl.SslHandler.decode(SslHandler.java:1041) 2017-07-13T15:20:14.147+05:30 [APP/PROC/WEB/0] [OUT] io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:411) 2017-07-13T15:20:14.147+05:30 [APP/PROC/WEB/0] [OUT] io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:248) 2017-07-13T15:20:14.147+05:30 [APP/PROC/WEB/0] [OUT] io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1334)

推荐答案

数据流服务器实现

名称spring-cloud-dataflow-server-cloudfoundry版本1.2.2.启用的功能

Name spring-cloud-dataflow-server-cloudfoundry Version 1.2.2.RELEASE Enabled Features

分析YY流任务Y

安全信息

启用身份验证X授权已启用X表单登录X认证的X用户名N/A角色[]

Authentication Enabled X Authorization Enabled X Form Login X Authenticated X Username N/A Roles []

版本信息

实施1.2.2发行版(spring-cloud-dataflow-server-cloudfoundry)核心1.2.2.RELEASE(Spring Cloud数据流核心)资讯主页1.2.1.RELEASE(Spring Cloud Dataflow用户界面)运行时环境-App Deployer

Implementation 1.2.2.RELEASE (spring-cloud-dataflow-server-cloudfoundry) Core 1.2.2.RELEASE (Spring Cloud Data Flow Core) Dashboard 1.2.1.RELEASE (Spring Cloud Dataflow UI) Runtime Environment - App Deployer

实施版本1.2.1发行名称CloudFoundryAppDeployerSpi版本1.2.1.RELEASEJava版本1.8.0_131平台Api版本2.65.0平台客户端版本2.14.0.RELEASE平台主机版本未知平台类型Cloud FoundrySpring Boot版本1.5.4.RELEASE春季版本4.3.9.RELEASEApp Deployer的特定于平台的信息

Implementation Version 1.2.1.RELEASE Name CloudFoundryAppDeployer Spi Version 1.2.1.RELEASE Java Version 1.8.0_131 Platform Api Version 2.65.0 Platform Client Version 2.14.0.RELEASE Platform Host Version unknown Platform Type Cloud Foundry Spring Boot Version 1.5.4.RELEASE Spring Version 4.3.9.RELEASE Platform-specific Information of the App Deployer

API端点 https://api.system.titan.lab.emc.com 运行时环境-任务启动器

API Endpoint https://api.system.titan.lab.emc.com Runtime Environment - Task Launcher

实施版本1.2.1发行版名称CloudFoundry2630AndLaterTaskLauncherSpi版本1.2.1.RELEASEJava版本1.8.0_131平台Api版本2.65.0平台客户端版本2.14.0.RELEASE平台主机版本未知平台类型Cloud FoundrySpring Boot版本1.5.4.RELEASE春季版本4.3.9.RELEASE任务启动器的特定于平台的信息

ImplementationVersion 1.2.1.RELEASE Name CloudFoundry2630AndLaterTaskLauncher Spi Version 1.2.1.RELEASE Java Version 1.8.0_131 Platform Api Version 2.65.0 Platform Client Version 2.14.0.RELEASE Platform Host Version unknown Platform Type Cloud Foundry Spring Boot Version 1.5.4.RELEASE Spring Version 4.3.9.RELEASE Platform-specific Information of the Task Launcher

API端点 https://api.system.titan.lab.emc.com

PCF 1.11版

这篇关于CloudFoundry上的Spring Cloud数据流的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持IT屋!

查看全文
登录 关闭
扫码关注1秒登录
发送“验证码”获取 | 15天全站免登陆