I'm trying to deploy DCAE (along with some supporting projects-specifically
consul, dmaap, log, msb, policy, robot, and sdc), and I'm seeing a problem with
hv-ves collector (version 1.1.0-SNAPSHOT). I've attached the logs.
This deployment has worked in the past, and it's possible there's an issue in
my environment, but I need someone to interpret the logs to tell me what's
wrong.
Jack Lucas
AT&T Laboratories
Middletown, NJ 07748 USA
[email protected]
-=-=-=-=-=-=-=-=-=-=-=-
Links: You receive all messages sent to this group.
View/Reply Online (#16476): https://lists.onap.org/g/onap-discuss/message/16476
Mute This Topic: https://lists.onap.org/mt/30918796/21656
Group Owner: [email protected]
Unsubscribe: https://lists.onap.org/g/onap-discuss/unsub
[[email protected]]
-=-=-=-=-=-=-=-=-=-=-=-
Service started with pid=7
| 2019-04-04T20:05:46.107Z |
ae.collectors.veshv.main.servers.HealthCheckServer | INFO | Health check
server is up and listening on 0:0:0:0:0:0:0:0%0:6060 | | |
InstanceID=5d1e0ab3-7e45-400d-9e5a-d242d3753ca7,
ServerFQDN=dcae-hv-ves-collector | main
| 2019-04-04T20:05:47.522Z |
org.onap.dcae.collectors.veshv.main | INFO | Using configuration:
HvVesConfiguration(server=ServerConfiguration(listenPort=6061,
idleTimeout=PT1M, maxPayloadSizeBytes=1048576),
cbs=CbsConfiguration(firstRequestDelay=PT10S, requestInterval=PT5S),
security=SecurityConfiguration(keys=None),
collector=CollectorConfiguration(maxRequestSizeBytes=1048576,
kafkaServers=message-router-kafka:9092,
routing=Routing(routes=[Route(domain=perf3gpp, targetTopic=HV_VES_PERF3GPP,
partitioning=(org.onap.ves.VesEventOuterClass.CommonEventHeader) ->
kotlin.Int)]), dummyMode=false), logLevel=INFO) | | | |
elastic-2
| 2019-04-04T20:05:48.240Z |
p.dcae.collectors.veshv.impl.socket.NettyTcpServer | INFO | Collector
configured with SSL disabled | | | | elastic-2
| 2019-04-04T20:05:48.290Z |
.onap.dcae.collectors.veshv.main.servers.VesServer | INFO | HighVolume VES
Collector is up and listening on 0:0:0:0:0:0:0:0%0:6061 | |
| InstanceID=5d1e0ab3-7e45-400d-9e5a-d242d3753ca7,
ServerFQDN=dcae-hv-ves-collector | elastic-2
| 2019-04-04T20:05:49.723Z |
tors.veshv.impl.adapters.ConfigurationProviderImpl | INFO | CBS client
successfully created | | |
InstanceID=5d1e0ab3-7e45-400d-9e5a-d242d3753ca7,
ServerFQDN=dcae-hv-ves-collector | reactor-http-epoll-1
| 2019-04-04T20:06:00.152Z |
tors.veshv.impl.adapters.ConfigurationProviderImpl | INFO | Received new
configuration:
{"streams_publishes":{"perf3gpp":{"type":"kafka","kafka_info":{"bootstrap_servers":"message-router-kafka:9092","topic_name":"HV_VES_PERF3GPP"}}}}
| | | InstanceID=5d1e0ab3-7e45-400d-9e5a-d242d3753ca7,
ServerFQDN=dcae-hv-ves-collector | reactor-http-epoll-1
| 2019-04-04T20:06:00.187Z |
tors.veshv.impl.adapters.ConfigurationProviderImpl | ERROR | Error
while creating configuration: Failed to parse configuration | |
| InstanceID=5d1e0ab3-7e45-400d-9e5a-d242d3753ca7,
ServerFQDN=dcae-hv-ves-collector | reactor-http-epoll-1
| 2019-04-04T20:06:00.211Z |
tors.veshv.impl.adapters.ConfigurationProviderImpl | WARN | Exception from
configuration provider client, retrying subscription | |
java.lang.NullPointerException: null
at
org.onap.dcae.collectors.veshv.impl.adapters.ConfigurationProviderImpl$createCollectorConfiguration$1.invoke(ConfigurationProviderImpl.kt:92)
at
org.onap.dcae.collectors.veshv.impl.adapters.ConfigurationProviderImpl$createCollectorConfiguration$1.invoke(ConfigurationProviderImpl.kt:45)
at
org.onap.dcae.collectors.veshv.config.api.model.RoutingKt.routing(Routing.kt:46)
at
org.onap.dcae.collectors.veshv.impl.adapters.ConfigurationProviderImpl.createCollectorConfiguration(ConfigurationProviderImpl.kt:91)
... 48 common frames omitted
Wrapped by: org.onap.dcae.collectors.veshv.impl.adapters.ParsingException:
Failed to parse configuration
at
org.onap.dcae.collectors.veshv.impl.adapters.ConfigurationProviderImpl.createCollectorConfiguration(ConfigurationProviderImpl.kt:102)
at
org.onap.dcae.collectors.veshv.impl.adapters.ConfigurationProviderImpl.access$createCollectorConfiguration(ConfigurationProviderImpl.kt:45)
at
org.onap.dcae.collectors.veshv.impl.adapters.ConfigurationProviderImpl$handleUpdates$2.invoke(ConfigurationProviderImpl.kt:83)
at
org.onap.dcae.collectors.veshv.impl.adapters.ConfigurationProviderImpl$handleUpdates$2.invoke(ConfigurationProviderImpl.kt:45)
at
org.onap.dcae.collectors.veshv.impl.adapters.ConfigurationProviderImpl$sam$java_util_function_Function$0.apply(ConfigurationProviderImpl.kt)
at reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:100)
at
reactor.core.publisher.FluxPeek$PeekSubscriber.onNext(FluxPeek.java:192)
at
reactor.core.publisher.FluxDistinctUntilChanged$DistinctUntilChangedSubscriber.tryOnNext(FluxDistinctUntilChanged.java:120)
at
reactor.core.publisher.FluxDistinctUntilChanged$DistinctUntilChangedSubscriber.onNext(FluxDistinctUntilChanged.java:94)
at
reactor.core.publisher.FluxFlatMap$FlatMapMain.tryEmit(FluxFlatMap.java:501)
at
reactor.core.publisher.FluxFlatMap$FlatMapInner.onNext(FluxFlatMap.java:943)
at
reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at
reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1505)
at
reactor.core.publisher.MonoFlatMap$FlatMapInner.onNext(MonoFlatMap.java:241)
at
reactor.core.publisher.FluxDoFinally$DoFinallySubscriber.onNext(FluxDoFinally.java:123)
at
reactor.core.publisher.FluxHandle$HandleSubscriber.onNext(FluxHandle.java:113)
at
reactor.core.publisher.FluxMapFuseable$MapFuseableConditionalSubscriber.onNext(FluxMapFuseable.java:287)
at
reactor.core.publisher.FluxUsing$UsingFuseableSubscriber.onNext(FluxUsing.java:350)
at
reactor.core.publisher.FluxFilterFuseable$FilterFuseableSubscriber.onNext(FluxFilterFuseable.java:113)
at
reactor.core.publisher.FluxPeekFuseable$PeekFuseableConditionalSubscriber.onNext(FluxPeekFuseable.java:486)
at
reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1505)
at
reactor.core.publisher.MonoReduceSeed$ReduceSeedSubscriber.onComplete(MonoReduceSeed.java:156)
at
reactor.core.publisher.FluxMap$MapSubscriber.onComplete(FluxMap.java:136)
at
reactor.netty.channel.FluxReceive.terminateReceiver(FluxReceive.java:372)
at reactor.netty.channel.FluxReceive.drainReceiver(FluxReceive.java:196)
at
reactor.netty.channel.FluxReceive.onInboundComplete(FluxReceive.java:337)
at
reactor.netty.channel.ChannelOperations.onInboundComplete(ChannelOperations.java:334)
at
reactor.netty.channel.ChannelOperations.terminate(ChannelOperations.java:381)
at
reactor.netty.http.client.HttpClientOperations.onInboundNext(HttpClientOperations.java:520)
at
reactor.netty.channel.ChannelOperationsHandler.channelRead(ChannelOperationsHandler.java:141)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at
io.netty.channel.CombinedChannelDuplexHandler$DelegatingChannelHandlerContext.fireChannelRead(CombinedChannelDuplexHandler.java:438)
at
io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:323)
at
io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:297)
at
io.netty.channel.CombinedChannelDuplexHandler.channelRead(CombinedChannelDuplexHandler.java:253)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at
io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1434)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at
io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:965)
at
io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.epollInReady(AbstractEpollStreamChannel.java:799)
at
io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:433)
at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:330)
at
io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:909)
at java.base/java.lang.Thread.run(Thread.java:834)
| InstanceID=5d1e0ab3-7e45-400d-9e5a-d242d3753ca7,
ServerFQDN=dcae-hv-ves-collector | reactor-http-epoll-1
| 2019-04-04T20:06:15.331Z |
tors.veshv.impl.adapters.ConfigurationProviderImpl | INFO | Received new
configuration:
{"streams_publishes":{"perf3gpp":{"type":"kafka","kafka_info":{"bootstrap_servers":"message-router-kafka:9092","topic_name":"HV_VES_PERF3GPP"}}}}
| | | InstanceID=5d1e0ab3-7e45-400d-9e5a-d242d3753ca7,
ServerFQDN=dcae-hv-ves-collector | reactor-http-epoll-1
| 2019-04-04T20:06:15.333Z |
tors.veshv.impl.adapters.ConfigurationProviderImpl | ERROR | Error
while creating configuration: Failed to parse configuration | |
| InstanceID=5d1e0ab3-7e45-400d-9e5a-d242d3753ca7,
ServerFQDN=dcae-hv-ves-collector | reactor-http-epoll-1
| 2019-04-04T20:06:15.334Z |
tors.veshv.impl.adapters.ConfigurationProviderImpl | WARN | Exception from
configuration provider client, retrying subscription | |
java.lang.NullPointerException: null
at
org.onap.dcae.collectors.veshv.impl.adapters.ConfigurationProviderImpl$createCollectorConfiguration$1.invoke(ConfigurationProviderImpl.kt:92)
at
org.onap.dcae.collectors.veshv.impl.adapters.ConfigurationProviderImpl$createCollectorConfiguration$1.invoke(ConfigurationProviderImpl.kt:45)
at
org.onap.dcae.collectors.veshv.config.api.model.RoutingKt.routing(Routing.kt:46)
at
org.onap.dcae.collectors.veshv.impl.adapters.ConfigurationProviderImpl.createCollectorConfiguration(ConfigurationProviderImpl.kt:91)
... 48 common frames omitted
Wrapped by: org.onap.dcae.collectors.veshv.impl.adapters.ParsingException:
Failed to parse configuration
at
org.onap.dcae.collectors.veshv.impl.adapters.ConfigurationProviderImpl.createCollectorConfiguration(ConfigurationProviderImpl.kt:102)
at
org.onap.dcae.collectors.veshv.impl.adapters.ConfigurationProviderImpl.access$createCollectorConfiguration(ConfigurationProviderImpl.kt:45)
at
org.onap.dcae.collectors.veshv.impl.adapters.ConfigurationProviderImpl$handleUpdates$2.invoke(ConfigurationProviderImpl.kt:83)
at
org.onap.dcae.collectors.veshv.impl.adapters.ConfigurationProviderImpl$handleUpdates$2.invoke(ConfigurationProviderImpl.kt:45)
at
org.onap.dcae.collectors.veshv.impl.adapters.ConfigurationProviderImpl$sam$java_util_function_Function$0.apply(ConfigurationProviderImpl.kt)
at reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:100)
at
reactor.core.publisher.FluxPeek$PeekSubscriber.onNext(FluxPeek.java:192)
at
reactor.core.publisher.FluxDistinctUntilChanged$DistinctUntilChangedSubscriber.tryOnNext(FluxDistinctUntilChanged.java:120)
at
reactor.core.publisher.FluxDistinctUntilChanged$DistinctUntilChangedSubscriber.onNext(FluxDistinctUntilChanged.java:94)
at
reactor.core.publisher.FluxFlatMap$FlatMapMain.tryEmit(FluxFlatMap.java:501)
at
reactor.core.publisher.FluxFlatMap$FlatMapInner.onNext(FluxFlatMap.java:943)
at
reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at
reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1505)
at
reactor.core.publisher.MonoFlatMap$FlatMapInner.onNext(MonoFlatMap.java:241)
at
reactor.core.publisher.FluxDoFinally$DoFinallySubscriber.onNext(FluxDoFinally.java:123)
at
reactor.core.publisher.FluxHandle$HandleSubscriber.onNext(FluxHandle.java:113)
at
reactor.core.publisher.FluxMapFuseable$MapFuseableConditionalSubscriber.onNext(FluxMapFuseable.java:287)
at
reactor.core.publisher.FluxUsing$UsingFuseableSubscriber.onNext(FluxUsing.java:350)
at
reactor.core.publisher.FluxFilterFuseable$FilterFuseableSubscriber.onNext(FluxFilterFuseable.java:113)
at
reactor.core.publisher.FluxPeekFuseable$PeekFuseableConditionalSubscriber.onNext(FluxPeekFuseable.java:486)
at
reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1505)
at
reactor.core.publisher.MonoReduceSeed$ReduceSeedSubscriber.onComplete(MonoReduceSeed.java:156)
at
reactor.core.publisher.FluxMap$MapSubscriber.onComplete(FluxMap.java:136)
at
reactor.netty.channel.FluxReceive.terminateReceiver(FluxReceive.java:372)
at reactor.netty.channel.FluxReceive.drainReceiver(FluxReceive.java:196)
at
reactor.netty.channel.FluxReceive.onInboundComplete(FluxReceive.java:337)
at
reactor.netty.channel.ChannelOperations.onInboundComplete(ChannelOperations.java:334)
at
reactor.netty.channel.ChannelOperations.terminate(ChannelOperations.java:381)
at
reactor.netty.http.client.HttpClientOperations.onInboundNext(HttpClientOperations.java:520)
at
reactor.netty.channel.ChannelOperationsHandler.channelRead(ChannelOperationsHandler.java:141)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at
io.netty.channel.CombinedChannelDuplexHandler$DelegatingChannelHandlerContext.fireChannelRead(CombinedChannelDuplexHandler.java:438)
at
io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:323)
at
io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:297)
at
io.netty.channel.CombinedChannelDuplexHandler.channelRead(CombinedChannelDuplexHandler.java:253)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at
io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1434)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at
io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:965)
at
io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.epollInReady(AbstractEpollStreamChannel.java:799)
at
io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:433)
at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:330)
at
io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:909)
at java.base/java.lang.Thread.run(Thread.java:834)
| InstanceID=5d1e0ab3-7e45-400d-9e5a-d242d3753ca7,
ServerFQDN=dcae-hv-ves-collector | reactor-http-epoll-1
| 2019-04-04T20:06:30.438Z |
tors.veshv.impl.adapters.ConfigurationProviderImpl | INFO | Received new
configuration:
{"streams_publishes":{"perf3gpp":{"type":"kafka","kafka_info":{"bootstrap_servers":"message-router-kafka:9092","topic_name":"HV_VES_PERF3GPP"}}}}
| | | InstanceID=5d1e0ab3-7e45-400d-9e5a-d242d3753ca7,
ServerFQDN=dcae-hv-ves-collector | reactor-http-epoll-1
| 2019-04-04T20:06:30.440Z |
tors.veshv.impl.adapters.ConfigurationProviderImpl | ERROR | Error
while creating configuration: Failed to parse configuration | |
| InstanceID=5d1e0ab3-7e45-400d-9e5a-d242d3753ca7,
ServerFQDN=dcae-hv-ves-collector | reactor-http-epoll-1
| 2019-04-04T20:06:30.441Z |
tors.veshv.impl.adapters.ConfigurationProviderImpl | WARN | Exception from
configuration provider client, retrying subscription | |
java.lang.NullPointerException: null
at
org.onap.dcae.collectors.veshv.impl.adapters.ConfigurationProviderImpl$createCollectorConfiguration$1.invoke(ConfigurationProviderImpl.kt:92)
at
org.onap.dcae.collectors.veshv.impl.adapters.ConfigurationProviderImpl$createCollectorConfiguration$1.invoke(ConfigurationProviderImpl.kt:45)
at
org.onap.dcae.collectors.veshv.config.api.model.RoutingKt.routing(Routing.kt:46)
at
org.onap.dcae.collectors.veshv.impl.adapters.ConfigurationProviderImpl.createCollectorConfiguration(ConfigurationProviderImpl.kt:91)
... 48 common frames omitted
Wrapped by: org.onap.dcae.collectors.veshv.impl.adapters.ParsingException:
Failed to parse configuration
at
org.onap.dcae.collectors.veshv.impl.adapters.ConfigurationProviderImpl.createCollectorConfiguration(ConfigurationProviderImpl.kt:102)
at
org.onap.dcae.collectors.veshv.impl.adapters.ConfigurationProviderImpl.access$createCollectorConfiguration(ConfigurationProviderImpl.kt:45)
at
org.onap.dcae.collectors.veshv.impl.adapters.ConfigurationProviderImpl$handleUpdates$2.invoke(ConfigurationProviderImpl.kt:83)
at
org.onap.dcae.collectors.veshv.impl.adapters.ConfigurationProviderImpl$handleUpdates$2.invoke(ConfigurationProviderImpl.kt:45)
at
org.onap.dcae.collectors.veshv.impl.adapters.ConfigurationProviderImpl$sam$java_util_function_Function$0.apply(ConfigurationProviderImpl.kt)
at reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:100)
at
reactor.core.publisher.FluxPeek$PeekSubscriber.onNext(FluxPeek.java:192)
at
reactor.core.publisher.FluxDistinctUntilChanged$DistinctUntilChangedSubscriber.tryOnNext(FluxDistinctUntilChanged.java:120)
at
reactor.core.publisher.FluxDistinctUntilChanged$DistinctUntilChangedSubscriber.onNext(FluxDistinctUntilChanged.java:94)
at
reactor.core.publisher.FluxFlatMap$FlatMapMain.tryEmit(FluxFlatMap.java:501)
at
reactor.core.publisher.FluxFlatMap$FlatMapInner.onNext(FluxFlatMap.java:943)
at
reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at
reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1505)
at
reactor.core.publisher.MonoFlatMap$FlatMapInner.onNext(MonoFlatMap.java:241)
at
reactor.core.publisher.FluxDoFinally$DoFinallySubscriber.onNext(FluxDoFinally.java:123)
at
reactor.core.publisher.FluxHandle$HandleSubscriber.onNext(FluxHandle.java:113)
at
reactor.core.publisher.FluxMapFuseable$MapFuseableConditionalSubscriber.onNext(FluxMapFuseable.java:287)
at
reactor.core.publisher.FluxUsing$UsingFuseableSubscriber.onNext(FluxUsing.java:350)
at
reactor.core.publisher.FluxFilterFuseable$FilterFuseableSubscriber.onNext(FluxFilterFuseable.java:113)
at
reactor.core.publisher.FluxPeekFuseable$PeekFuseableConditionalSubscriber.onNext(FluxPeekFuseable.java:486)
at
reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1505)
at
reactor.core.publisher.MonoReduceSeed$ReduceSeedSubscriber.onComplete(MonoReduceSeed.java:156)
at
reactor.core.publisher.FluxMap$MapSubscriber.onComplete(FluxMap.java:136)
at
reactor.netty.channel.FluxReceive.terminateReceiver(FluxReceive.java:372)
at reactor.netty.channel.FluxReceive.drainReceiver(FluxReceive.java:196)
at
reactor.netty.channel.FluxReceive.onInboundComplete(FluxReceive.java:337)
at
reactor.netty.channel.ChannelOperations.onInboundComplete(ChannelOperations.java:334)
at
reactor.netty.channel.ChannelOperations.terminate(ChannelOperations.java:381)
at
reactor.netty.http.client.HttpClientOperations.onInboundNext(HttpClientOperations.java:520)
at
reactor.netty.channel.ChannelOperationsHandler.channelRead(ChannelOperationsHandler.java:141)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at
io.netty.channel.CombinedChannelDuplexHandler$DelegatingChannelHandlerContext.fireChannelRead(CombinedChannelDuplexHandler.java:438)
at
io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:323)
at
io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:297)
at
io.netty.channel.CombinedChannelDuplexHandler.channelRead(CombinedChannelDuplexHandler.java:253)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at
io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1434)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at
io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:965)
at
io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.epollInReady(AbstractEpollStreamChannel.java:799)
at
io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:433)
at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:330)
at
io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:909)
at java.base/java.lang.Thread.run(Thread.java:834)
| InstanceID=5d1e0ab3-7e45-400d-9e5a-d242d3753ca7,
ServerFQDN=dcae-hv-ves-collector | reactor-http-epoll-1
| 2019-04-04T20:06:45.949Z |
tors.veshv.impl.adapters.ConfigurationProviderImpl | INFO | Received new
configuration:
{"streams_publishes":{"perf3gpp":{"type":"kafka","kafka_info":{"bootstrap_servers":"message-router-kafka:9092","topic_name":"HV_VES_PERF3GPP"}}}}
| | | InstanceID=5d1e0ab3-7e45-400d-9e5a-d242d3753ca7,
ServerFQDN=dcae-hv-ves-collector | reactor-http-epoll-1
| 2019-04-04T20:06:45.950Z |
tors.veshv.impl.adapters.ConfigurationProviderImpl | ERROR | Error
while creating configuration: Failed to parse configuration | |
| InstanceID=5d1e0ab3-7e45-400d-9e5a-d242d3753ca7,
ServerFQDN=dcae-hv-ves-collector | reactor-http-epoll-1
| 2019-04-04T20:06:45.951Z |
tors.veshv.impl.adapters.ConfigurationProviderImpl | WARN | Exception from
configuration provider client, retrying subscription | |
java.lang.NullPointerException: null
at
org.onap.dcae.collectors.veshv.impl.adapters.ConfigurationProviderImpl$createCollectorConfiguration$1.invoke(ConfigurationProviderImpl.kt:92)
at
org.onap.dcae.collectors.veshv.impl.adapters.ConfigurationProviderImpl$createCollectorConfiguration$1.invoke(ConfigurationProviderImpl.kt:45)
at
org.onap.dcae.collectors.veshv.config.api.model.RoutingKt.routing(Routing.kt:46)
at
org.onap.dcae.collectors.veshv.impl.adapters.ConfigurationProviderImpl.createCollectorConfiguration(ConfigurationProviderImpl.kt:91)
... 48 common frames omitted
Wrapped by: org.onap.dcae.collectors.veshv.impl.adapters.ParsingException:
Failed to parse configuration
at
org.onap.dcae.collectors.veshv.impl.adapters.ConfigurationProviderImpl.createCollectorConfiguration(ConfigurationProviderImpl.kt:102)
at
org.onap.dcae.collectors.veshv.impl.adapters.ConfigurationProviderImpl.access$createCollectorConfiguration(ConfigurationProviderImpl.kt:45)
at
org.onap.dcae.collectors.veshv.impl.adapters.ConfigurationProviderImpl$handleUpdates$2.invoke(ConfigurationProviderImpl.kt:83)
at
org.onap.dcae.collectors.veshv.impl.adapters.ConfigurationProviderImpl$handleUpdates$2.invoke(ConfigurationProviderImpl.kt:45)
at
org.onap.dcae.collectors.veshv.impl.adapters.ConfigurationProviderImpl$sam$java_util_function_Function$0.apply(ConfigurationProviderImpl.kt)
at reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:100)
at
reactor.core.publisher.FluxPeek$PeekSubscriber.onNext(FluxPeek.java:192)
at
reactor.core.publisher.FluxDistinctUntilChanged$DistinctUntilChangedSubscriber.tryOnNext(FluxDistinctUntilChanged.java:120)
at
reactor.core.publisher.FluxDistinctUntilChanged$DistinctUntilChangedSubscriber.onNext(FluxDistinctUntilChanged.java:94)
at
reactor.core.publisher.FluxFlatMap$FlatMapMain.tryEmit(FluxFlatMap.java:501)
at
reactor.core.publisher.FluxFlatMap$FlatMapInner.onNext(FluxFlatMap.java:943)
at
reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at
reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1505)
at
reactor.core.publisher.MonoFlatMap$FlatMapInner.onNext(MonoFlatMap.java:241)
at
reactor.core.publisher.FluxDoFinally$DoFinallySubscriber.onNext(FluxDoFinally.java:123)
at
reactor.core.publisher.FluxHandle$HandleSubscriber.onNext(FluxHandle.java:113)
at
reactor.core.publisher.FluxMapFuseable$MapFuseableConditionalSubscriber.onNext(FluxMapFuseable.java:287)
at
reactor.core.publisher.FluxUsing$UsingFuseableSubscriber.onNext(FluxUsing.java:350)
at
reactor.core.publisher.FluxFilterFuseable$FilterFuseableSubscriber.onNext(FluxFilterFuseable.java:113)
at
reactor.core.publisher.FluxPeekFuseable$PeekFuseableConditionalSubscriber.onNext(FluxPeekFuseable.java:486)
at
reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1505)
at
reactor.core.publisher.MonoReduceSeed$ReduceSeedSubscriber.onComplete(MonoReduceSeed.java:156)
at
reactor.core.publisher.FluxMap$MapSubscriber.onComplete(FluxMap.java:136)
at
reactor.netty.channel.FluxReceive.terminateReceiver(FluxReceive.java:372)
at reactor.netty.channel.FluxReceive.drainReceiver(FluxReceive.java:196)
at
reactor.netty.channel.FluxReceive.onInboundComplete(FluxReceive.java:337)
at
reactor.netty.channel.ChannelOperations.onInboundComplete(ChannelOperations.java:334)
at
reactor.netty.channel.ChannelOperations.terminate(ChannelOperations.java:381)
at
reactor.netty.http.client.HttpClientOperations.onInboundNext(HttpClientOperations.java:520)
at
reactor.netty.channel.ChannelOperationsHandler.channelRead(ChannelOperationsHandler.java:141)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at
io.netty.channel.CombinedChannelDuplexHandler$DelegatingChannelHandlerContext.fireChannelRead(CombinedChannelDuplexHandler.java:438)
at
io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:323)
at
io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:297)
at
io.netty.channel.CombinedChannelDuplexHandler.channelRead(CombinedChannelDuplexHandler.java:253)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at
io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1434)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at
io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:965)
at
io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.epollInReady(AbstractEpollStreamChannel.java:799)
at
io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:433)
at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:330)
at
io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:909)
at java.base/java.lang.Thread.run(Thread.java:834)
| InstanceID=5d1e0ab3-7e45-400d-9e5a-d242d3753ca7,
ServerFQDN=dcae-hv-ves-collector | reactor-http-epoll-1
| 2019-04-04T20:07:01.036Z |
tors.veshv.impl.adapters.ConfigurationProviderImpl | INFO | Received new
configuration:
{"streams_publishes":{"perf3gpp":{"type":"kafka","kafka_info":{"bootstrap_servers":"message-router-kafka:9092","topic_name":"HV_VES_PERF3GPP"}}}}
| | | InstanceID=5d1e0ab3-7e45-400d-9e5a-d242d3753ca7,
ServerFQDN=dcae-hv-ves-collector | reactor-http-epoll-1
| 2019-04-04T20:07:01.046Z |
tors.veshv.impl.adapters.ConfigurationProviderImpl | ERROR | Error
while creating configuration: Failed to parse configuration | |
| InstanceID=5d1e0ab3-7e45-400d-9e5a-d242d3753ca7,
ServerFQDN=dcae-hv-ves-collector | reactor-http-epoll-1
| 2019-04-04T20:07:01.047Z |
tors.veshv.impl.adapters.ConfigurationProviderImpl | WARN | Exception from
configuration provider client, retrying subscription | |
java.lang.NullPointerException: null
at
org.onap.dcae.collectors.veshv.impl.adapters.ConfigurationProviderImpl$createCollectorConfiguration$1.invoke(ConfigurationProviderImpl.kt:92)
at
org.onap.dcae.collectors.veshv.impl.adapters.ConfigurationProviderImpl$createCollectorConfiguration$1.invoke(ConfigurationProviderImpl.kt:45)
at
org.onap.dcae.collectors.veshv.config.api.model.RoutingKt.routing(Routing.kt:46)
at
org.onap.dcae.collectors.veshv.impl.adapters.ConfigurationProviderImpl.createCollectorConfiguration(ConfigurationProviderImpl.kt:91)
... 48 common frames omitted
Wrapped by: org.onap.dcae.collectors.veshv.impl.adapters.ParsingException:
Failed to parse configuration
at
org.onap.dcae.collectors.veshv.impl.adapters.ConfigurationProviderImpl.createCollectorConfiguration(ConfigurationProviderImpl.kt:102)
at
org.onap.dcae.collectors.veshv.impl.adapters.ConfigurationProviderImpl.access$createCollectorConfiguration(ConfigurationProviderImpl.kt:45)
at
org.onap.dcae.collectors.veshv.impl.adapters.ConfigurationProviderImpl$handleUpdates$2.invoke(ConfigurationProviderImpl.kt:83)
at
org.onap.dcae.collectors.veshv.impl.adapters.ConfigurationProviderImpl$handleUpdates$2.invoke(ConfigurationProviderImpl.kt:45)
at
org.onap.dcae.collectors.veshv.impl.adapters.ConfigurationProviderImpl$sam$java_util_function_Function$0.apply(ConfigurationProviderImpl.kt)
at reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:100)
at
reactor.core.publisher.FluxPeek$PeekSubscriber.onNext(FluxPeek.java:192)
at
reactor.core.publisher.FluxDistinctUntilChanged$DistinctUntilChangedSubscriber.tryOnNext(FluxDistinctUntilChanged.java:120)
at
reactor.core.publisher.FluxDistinctUntilChanged$DistinctUntilChangedSubscriber.onNext(FluxDistinctUntilChanged.java:94)
at
reactor.core.publisher.FluxFlatMap$FlatMapMain.tryEmit(FluxFlatMap.java:501)
at
reactor.core.publisher.FluxFlatMap$FlatMapInner.onNext(FluxFlatMap.java:943)
at
reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
at
reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1505)
at
reactor.core.publisher.MonoFlatMap$FlatMapInner.onNext(MonoFlatMap.java:241)
at
reactor.core.publisher.FluxDoFinally$DoFinallySubscriber.onNext(FluxDoFinally.java:123)
at
reactor.core.publisher.FluxHandle$HandleSubscriber.onNext(FluxHandle.java:113)
at
reactor.core.publisher.FluxMapFuseable$MapFuseableConditionalSubscriber.onNext(FluxMapFuseable.java:287)
at
reactor.core.publisher.FluxUsing$UsingFuseableSubscriber.onNext(FluxUsing.java:350)
at
reactor.core.publisher.FluxFilterFuseable$FilterFuseableSubscriber.onNext(FluxFilterFuseable.java:113)
at
reactor.core.publisher.FluxPeekFuseable$PeekFuseableConditionalSubscriber.onNext(FluxPeekFuseable.java:486)
at
reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1505)
at
reactor.core.publisher.MonoReduceSeed$ReduceSeedSubscriber.onComplete(MonoReduceSeed.java:156)
at
reactor.core.publisher.FluxMap$MapSubscriber.onComplete(FluxMap.java:136)
at
reactor.netty.channel.FluxReceive.terminateReceiver(FluxReceive.java:372)
at reactor.netty.channel.FluxReceive.drainReceiver(FluxReceive.java:196)
at
reactor.netty.channel.FluxReceive.onInboundComplete(FluxReceive.java:337)
at
reactor.netty.channel.ChannelOperations.onInboundComplete(ChannelOperations.java:334)
at
reactor.netty.channel.ChannelOperations.terminate(ChannelOperations.java:381)
at
reactor.netty.http.client.HttpClientOperations.onInboundNext(HttpClientOperations.java:520)
at
reactor.netty.channel.ChannelOperationsHandler.channelRead(ChannelOperationsHandler.java:141)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at
io.netty.channel.CombinedChannelDuplexHandler$DelegatingChannelHandlerContext.fireChannelRead(CombinedChannelDuplexHandler.java:438)
at
io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:323)
at
io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:297)
at
io.netty.channel.CombinedChannelDuplexHandler.channelRead(CombinedChannelDuplexHandler.java:253)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at
io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1434)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at
io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:965)
at
io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.epollInReady(AbstractEpollStreamChannel.java:799)
at
io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:433)
at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:330)
at
io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:909)
at java.base/java.lang.Thread.run(Thread.java:834)
| InstanceID=5d1e0ab3-7e45-400d-9e5a-d242d3753ca7,
ServerFQDN=dcae-hv-ves-collector | reactor-http-epoll-1
| 2019-04-04T20:07:16.455Z |
tors.veshv.impl.adapters.ConfigurationProviderImpl | INFO | Received new
configuration:
{"streams_publishes":{"perf3gpp":{"type":"kafka","kafka_info":{"bootstrap_servers":"message-router-kafka:9092","topic_name":"HV_VES_PERF3GPP"}}}}
| | | InstanceID=5d1e0ab3-7e45-400d-9e5a-d242d3753ca7,
ServerFQDN=dcae-hv-ves-collector | reactor-http-epoll-1
| 2019-04-04T20:07:16.458Z |
tors.veshv.impl.adapters.ConfigurationProviderImpl | ERROR | Error
while creating configuration: Failed to parse configuration | |
| InstanceID=5d1e0ab3-7e45-400d-9e5a-d242d3753ca7,
ServerFQDN=dcae-hv-ves-collector | reactor-http-epoll-1
| 2019-04-04T20:07:16.477Z |
nap.dcae.collectors.veshv.factory.CollectorFactory | ERROR | Failed
to acquire configuration
org.onap.dcae.collectors.veshv.impl.adapters.ParsingException: Failed to parse
configuration | | |
InstanceID=5d1e0ab3-7e45-400d-9e5a-d242d3753ca7,
ServerFQDN=dcae-hv-ves-collector | reactor-http-epoll-1
| 2019-04-04T20:23:02.549Z |
reactor.netty.tcp.TcpServer | ERROR | [id: 0x004dc4a6,
L:/0:0:0:0:0:0:0:1%0:6060 - R:/0:0:0:0:0:0:0:1%0:49372]
onUncaughtException(SimpleConnection{channel=[id: 0x004dc4a6,
L:/0:0:0:0:0:0:0:1%0:6060 - R:/0:0:0:0:0:0:0:1%0:49372]}) | |
io.netty.channel.unix.Errors$NativeIoException: syscall:read(..) failed:
Connection reset by peer
at io.netty.channel.unix.FileDescriptor.readAddress(..)(Unknown Source)
| | reactor-http-epoll-3
| 2019-04-04T20:27:46.691Z |
reactor.netty.tcp.TcpServer | ERROR | [id: 0x4e6cf087,
L:/0:0:0:0:0:0:0:1%0:6060 - R:/0:0:0:0:0:0:0:1%0:33706]
onUncaughtException(SimpleConnection{channel=[id: 0x4e6cf087,
L:/0:0:0:0:0:0:0:1%0:6060 - R:/0:0:0:0:0:0:0:1%0:33706]}) | |
io.netty.channel.unix.Errors$NativeIoException: syscall:read(..) failed:
Connection reset by peer
at io.netty.channel.unix.FileDescriptor.readAddress(..)(Unknown Source)
| | reactor-http-epoll-2
| 2019-04-04T20:31:16.511Z |
reactor.netty.tcp.TcpServer | ERROR | [id: 0xe3960865,
L:/0:0:0:0:0:0:0:1%0:6060 - R:/0:0:0:0:0:0:0:1%0:43088]
onUncaughtException(SimpleConnection{channel=[id: 0xe3960865,
L:/0:0:0:0:0:0:0:1%0:6060 - R:/0:0:0:0:0:0:0:1%0:43088]}) | |
io.netty.channel.unix.Errors$NativeIoException: syscall:read(..) failed:
Connection reset by peer
at io.netty.channel.unix.FileDescriptor.readAddress(..)(Unknown Source)
| | reactor-http-epoll-4
