devinbost commented on issue #6332: (Flaky-test) Intermittent failure of ProxyParserTest.testRegexSubscription URL: https://github.com/apache/pulsar/issues/6332#issuecomment-587319767 There's an interesting warning the Github CI logs: ``` 04:57:30.842 [pulsar-proxy-io-39-2:io.netty.channel.DefaultChannelPipeline@1164] WARN io.netty.channel.DefaultChannelPipeline - An exceptionCaught() event was fired, and it reached at the tail of the pipeline. It usually means the last handler in the pipeline did not handle the exception. java.lang.UnsupportedOperationException: null ``` Here's the context of this exception: ``` 04:57:30.817 [pulsar-proxy-io-39-1:org.apache.pulsar.proxy.server.ProxyConnection@141] INFO org.apache.pulsar.proxy.server.ProxyConnection - [/10.1.0.4:33716] New connection opened 04:57:30.818 [pulsar-proxy-io-39-1:org.apache.pulsar.proxy.server.ProxyConnection@205] INFO org.apache.pulsar.proxy.server.ProxyConnection - [/10.1.0.4:33716] complete connection, init proxy handler. authenticated with none role null, hasProxyToBrokerUrl: false 04:57:30.819 [pulsar-client-io-94-2:org.apache.pulsar.client.impl.ConnectionPool@156] INFO org.apache.pulsar.client.impl.ConnectionPool - [[id: 0x06bebf8c, L:/10.1.0.4:33716 - R:fv-az98.h5sctpwyleze3eigx5cvfmuugc.cx.internal.cloudapp.net/10.1.0.4:35639]] Connected to server 04:57:30.834 [pulsar-proxy-io-39-1:org.apache.pulsar.client.impl.ConnectionPool@156] INFO org.apache.pulsar.client.impl.ConnectionPool - [[id: 0xee41bec9, L:/127.0.0.1:47482 - R:localhost/127.0.0.1:34991]] Connected to server 04:57:30.837 [pulsar-io-15-3:org.apache.pulsar.broker.service.ServerCnx@184] INFO org.apache.pulsar.broker.service.ServerCnx - New connection from /127.0.0.1:47482 04:57:30.840 [pulsar-proxy-io-39-2:org.apache.pulsar.proxy.server.ProxyConnection@141] INFO org.apache.pulsar.proxy.server.ProxyConnection - [/10.1.0.4:33720] New connection opened 04:57:30.841 [pulsar-proxy-io-39-2:org.apache.pulsar.proxy.server.ProxyConnection@205] INFO org.apache.pulsar.proxy.server.ProxyConnection - [/10.1.0.4:33720] complete connection, init proxy handler. authenticated with none role null, hasProxyToBrokerUrl: false 04:57:30.841 [pulsar-client-io-94-2:org.apache.pulsar.client.impl.ConnectionPool@156] INFO org.apache.pulsar.client.impl.ConnectionPool - [[id: 0xdf32e16c, L:/10.1.0.4:33720 - R:fv-az98.h5sctpwyleze3eigx5cvfmuugc.cx.internal.cloudapp.net/10.1.0.4:35639]] Connected to server 04:57:30.842 [pulsar-client-io-94-2:org.apache.pulsar.client.impl.ConsumerImpl@544] INFO org.apache.pulsar.client.impl.ConsumerImpl - [persistent://sample/test/local/topic1][ignored] Subscribing to topic on cnx [id: 0xdf32e16c, L:/10.1.0.4:33720 - R:fv-az98.h5sctpwyleze3eigx5cvfmuugc.cx.internal.cloudapp.net/10.1.0.4:35639] 04:57:30.842 [pulsar-proxy-io-39-2:io.netty.channel.DefaultChannelPipeline@1164] WARN io.netty.channel.DefaultChannelPipeline - An exceptionCaught() event was fired, and it reached at the tail of the pipeline. It usually means the last handler in the pipeline did not handle the exception. java.lang.UnsupportedOperationException: null at org.apache.pulsar.common.protocol.PulsarDecoder.handleSubscribe(PulsarDecoder.java:457) ~[pulsar-common-2.6.0-SNAPSHOT.jar:2.6.0-SNAPSHOT] at org.apache.pulsar.common.protocol.PulsarDecoder.channelRead(PulsarDecoder.java:216) ~[pulsar-common-2.6.0-SNAPSHOT.jar:2.6.0-SNAPSHOT] at org.apache.pulsar.proxy.server.ProxyConnection.channelRead(ProxyConnection.java:174) ~[classes/:?] at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:374) [netty-transport-4.1.43.Final.jar:4.1.43.Final] at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:360) [netty-transport-4.1.43.Final.jar:4.1.43.Final] at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:352) [netty-transport-4.1.43.Final.jar:4.1.43.Final] at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:326) [netty-codec-4.1.43.Final.jar:4.1.43.Final] at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:300) [netty-codec-4.1.43.Final.jar:4.1.43.Final] at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:374) [netty-transport-4.1.43.Final.jar:4.1.43.Final] at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:360) [netty-transport-4.1.43.Final.jar:4.1.43.Final] at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:352) [netty-transport-4.1.43.Final.jar:4.1.43.Final] at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1422) [netty-transport-4.1.43.Final.jar:4.1.43.Final] at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:374) [netty-transport-4.1.43.Final.jar:4.1.43.Final] at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:360) [netty-transport-4.1.43.Final.jar:4.1.43.Final] at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:931) [netty-transport-4.1.43.Final.jar:4.1.43.Final] at io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.epollInReady(AbstractEpollStreamChannel.java:792) [netty-transport-native-epoll-4.1.43.Final-linux-x86_64.jar:4.1.43.Final] at io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:502) [netty-transport-native-epoll-4.1.43.Final-linux-x86_64.jar:4.1.43.Final] at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:407) [netty-transport-native-epoll-4.1.43.Final-linux-x86_64.jar:4.1.43.Final] at io.netty.util.concurrent.SingleThreadEventExecutor$6.run(SingleThreadEventExecutor.java:1050) [netty-common-4.1.43.Final.jar:4.1.43.Final] at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) [netty-common-4.1.43.Final.jar:4.1.43.Final] at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) [netty-common-4.1.43.Final.jar:4.1.43.Final] at java.lang.Thread.run(Thread.java:748) [?:1.8.0_242] ``` Should this exception be an error, rather than a warning?
---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services
