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: issues-unsubscr...@nifi.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org