joewitt commented on PR #7830:
URL: https://github.com/apache/nifi/pull/7830#issuecomment-1744241664
It is alive and working - very cool. Need to learn more about what this
java agent exporter really does but the json output is interesting. I did note
after running for a minute or two I received a couple of these outputs. I was
making minor edits to the flow when it happened but not this processor so dont
have the underlying data it choked on.
`2023-10-02 22:32:53,888 WARN
[ListenOTLP[f3e6ea42-018a-1000-d8d4-3a6b40e25474]-1-1]
o.a.n.p.opentelemetry.ListenOTLP
ListenOTLP[id=f3e6ea42-018a-1000-d8d4-3a6b40e25474] Client Address
[/127.0.0.1:55410] Content-Type [APPLICATION_GRPC] processing failed
java.io.UncheckedIOException: Request parsing failed
at
org.apache.nifi.processors.opentelemetry.encoding.ProtobufServiceRequestReader.read(ProtobufServiceRequestReader.java:64)
at
org.apache.nifi.processors.opentelemetry.io.StandardRequestContentListener.readMessages(StandardRequestContentListener.java:165)
at
org.apache.nifi.processors.opentelemetry.io.StandardRequestContentListener.onSupportedRequest(StandardRequestContentListener.java:145)
at
org.apache.nifi.processors.opentelemetry.io.StandardRequestContentListener.onRequest(StandardRequestContentListener.java:109)
at
org.apache.nifi.processors.opentelemetry.server.Http2RequestFrameListener.onDataRead(Http2RequestFrameListener.java:177)
at
io.netty.handler.codec.http2.Http2FrameListenerDecorator.onDataRead(Http2FrameListenerDecorator.java:36)
at
io.netty.handler.codec.http2.Http2EmptyDataFrameListener.onDataRead(Http2EmptyDataFrameListener.java:49)
at
io.netty.handler.codec.http2.DefaultHttp2ConnectionDecoder$FrameReadListener.onDataRead(DefaultHttp2ConnectionDecoder.java:307)
at
io.netty.handler.codec.http2.DefaultHttp2FrameReader.readDataFrame(DefaultHttp2FrameReader.java:415)
at
io.netty.handler.codec.http2.DefaultHttp2FrameReader.processPayloadState(DefaultHttp2FrameReader.java:250)
at
io.netty.handler.codec.http2.DefaultHttp2FrameReader.readFrame(DefaultHttp2FrameReader.java:159)
at
io.netty.handler.codec.http2.DefaultHttp2ConnectionDecoder.decodeFrame(DefaultHttp2ConnectionDecoder.java:173)
at
io.netty.handler.codec.http2.DecoratingHttp2ConnectionDecoder.decodeFrame(DecoratingHttp2ConnectionDecoder.java:63)
at
io.netty.handler.codec.http2.Http2ConnectionHandler$FrameDecoder.decode(Http2ConnectionHandler.java:393)
at
io.netty.handler.codec.http2.Http2ConnectionHandler.decode(Http2ConnectionHandler.java:453)
at
io.netty.handler.codec.ByteToMessageDecoder.decodeRemovalReentryProtection(ByteToMessageDecoder.java:529)
at
io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:468)
at
io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:290)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:444)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412)
at io.netty.handler.ssl.SslHandler.unwrap(SslHandler.java:1471)
at
io.netty.handler.ssl.SslHandler.decodeJdkCompatible(SslHandler.java:1334)
at io.netty.handler.ssl.SslHandler.decode(SslHandler.java:1383)
at
io.netty.handler.codec.ByteToMessageDecoder.decodeRemovalReentryProtection(ByteToMessageDecoder.java:529)
at
io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:468)
at
io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:290)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:444)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412)
at
io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1410)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:440)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
at
io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:919)
at
io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:166)
at
io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:788)
at
io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:724)
at
io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:650)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562)
at
io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997)
at
io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
at
io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.base/java.lang.Thread.run(Thread.java:1583)
Caused by: com.google.protobuf.InvalidProtocolBufferException: Protocol
message had invalid UTF-8.
at
com.google.protobuf.InvalidProtocolBufferException.invalidUtf8(InvalidProtocolBufferException.java:172)
at
com.google.protobuf.Utf8$UnsafeProcessor.decodeUtf8Direct(Utf8.java:1434)
at com.google.protobuf.Utf8$Processor.decodeUtf8(Utf8.java:631)
at com.google.protobuf.Utf8.decodeUtf8(Utf8.java:331)
at
com.google.protobuf.CodedInputStream$UnsafeDirectNioDecoder.readStringRequireUtf8(CodedInputStream.java:1528)
at
io.opentelemetry.proto.metrics.v1.Metric$Builder.mergeFrom(Metric.java:1061)
at
io.opentelemetry.proto.metrics.v1.Metric$1.parsePartialFrom(Metric.java:2167)
at
io.opentelemetry.proto.metrics.v1.Metric$1.parsePartialFrom(Metric.java:2159)
at
com.google.protobuf.CodedInputStream$UnsafeDirectNioDecoder.readMessage(CodedInputStream.java:1600)
at
io.opentelemetry.proto.metrics.v1.ScopeMetrics$Builder.mergeFrom(ScopeMetrics.java:604)
at
io.opentelemetry.proto.metrics.v1.ScopeMetrics$1.parsePartialFrom(ScopeMetrics.java:1248)
at
io.opentelemetry.proto.metrics.v1.ScopeMetrics$1.parsePartialFrom(ScopeMetrics.java:1240)
at
com.google.protobuf.CodedInputStream$UnsafeDirectNioDecoder.readMessage(CodedInputStream.java:1600)
at
io.opentelemetry.proto.metrics.v1.ResourceMetrics$Builder.mergeFrom(ResourceMetrics.java:603)
at
io.opentelemetry.proto.metrics.v1.ResourceMetrics$1.parsePartialFrom(ResourceMetrics.java:1243)
at
io.opentelemetry.proto.metrics.v1.ResourceMetrics$1.parsePartialFrom(ResourceMetrics.java:1235)
at
com.google.protobuf.CodedInputStream$UnsafeDirectNioDecoder.readMessage(CodedInputStream.java:1600)
at
io.opentelemetry.proto.collector.metrics.v1.ExportMetricsServiceRequest$Builder.mergeFrom(ExportMetricsServiceRequest.java:469)
at
io.opentelemetry.proto.collector.metrics.v1.ExportMetricsServiceRequest$1.parsePartialFrom(ExportMetricsServiceRequest.java:915)
at
io.opentelemetry.proto.collector.metrics.v1.ExportMetricsServiceRequest$1.parsePartialFrom(ExportMetricsServiceRequest.java:907)
at com.google.protobuf.AbstractParser.parseFrom(AbstractParser.java:134)
at com.google.protobuf.AbstractParser.parseFrom(AbstractParser.java:149)
at com.google.protobuf.AbstractParser.parseFrom(AbstractParser.java:48)
at
org.apache.nifi.processors.opentelemetry.encoding.ProtobufServiceRequestReader.read(ProtobufServiceRequestReader.java:56)
... 42 common frames omitted`
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
