pulsar-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From GitBox <...@apache.org>
Subject [GitHub] sijie opened a new issue #2119: TopicPatternSubscription doesn't work through proxy
Date Mon, 09 Jul 2018 10:47:28 GMT
sijie opened a new issue #2119: TopicPatternSubscription doesn't work through proxy
URL: https://github.com/apache/incubator-pulsar/issues/2119
 
 
   #### Expected behavior
   
   pattern subscription should work with proxy
   
   #### Actual behavior
   
   pattern subscription doesn't work with proxy
   
   ```
   10:43:12.948 [pulsar-discovery-io-2-1] INFO  org.apache.pulsar.proxy.server.ProxyConnection
- [/172.19.0.1:55484] Connection closed
   10:43:13.961 [pulsar-discovery-io-2-3] INFO  org.apache.pulsar.proxy.server.ProxyConnection
- [/172.19.0.1:55486] New connection opened
   10:43:13.964 [pulsar-discovery-io-2-3] 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.api.PulsarDecoder.handleGetTopicsOfNamespace(PulsarDecoder.java:427)
~[org.apache.pulsar-pulsar-common-2.2.0-incubating-SNAPSHOT.jar:2.2.0-incubating-SNAPSHOT]
   	at org.apache.pulsar.common.api.PulsarDecoder.channelRead(PulsarDecoder.java:282) ~[org.apache.pulsar-pulsar-common-2.2.0-incubating-SNAPSHOT.jar:2.2.0-incubating-SNAPSHOT]
   	at org.apache.pulsar.proxy.server.ProxyConnection.channelRead(ProxyConnection.java:164)
~[org.apache.pulsar-pulsar-proxy-2.2.0-incubating-SNAPSHOT.jar:2.2.0-incubating-SNAPSHOT]
   	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
[io.netty-netty-all-4.1.22.Final.jar:4.1.22.Final]
   	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
[io.netty-netty-all-4.1.22.Final.jar:4.1.22.Final]
   	at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
[io.netty-netty-all-4.1.22.Final.jar:4.1.22.Final]
   	at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:310)
[io.netty-netty-all-4.1.22.Final.jar:4.1.22.Final]
   	at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:284)
[io.netty-netty-all-4.1.22.Final.jar:4.1.22.Final]
   	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
[io.netty-netty-all-4.1.22.Final.jar:4.1.22.Final]
   	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
[io.netty-netty-all-4.1.22.Final.jar:4.1.22.Final]
   	at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
[io.netty-netty-all-4.1.22.Final.jar:4.1.22.Final]
   	at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1414)
[io.netty-netty-all-4.1.22.Final.jar:4.1.22.Final]
   	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
[io.netty-netty-all-4.1.22.Final.jar:4.1.22.Final]
   	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
[io.netty-netty-all-4.1.22.Final.jar:4.1.22.Final]
   	at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:945)
[io.netty-netty-all-4.1.22.Final.jar:4.1.22.Final]
   	at io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.epollInReady(AbstractEpollStreamChannel.java:806)
[io.netty-netty-all-4.1.22.Final.jar:4.1.22.Final]
   	at io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:404) [io.netty-netty-all-4.1.22.Final.jar:4.1.22.Final]
   	at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:304) [io.netty-netty-all-4.1.22.Final.jar:4.1.22.Final]
   	at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:886)
[io.netty-netty-all-4.1.22.Final.jar:4.1.22.Final]
   	at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
[io.netty-netty-all-4.1.22.Final.jar:4.1.22.Final]
   	at java.lang.Thread.run(Thread.java:748) [?:1.8.0_151]
   10:43:13.964 [pulsar-discovery-io-2-3] WARN  org.apache.pulsar.proxy.server.ProxyConnection
- [/172.19.0.1:55486] Got exception UnsupportedOperationException : null
   java.lang.UnsupportedOperationException: null
   	at org.apache.pulsar.common.api.PulsarDecoder.handleGetTopicsOfNamespace(PulsarDecoder.java:427)
~[org.apache.pulsar-pulsar-common-2.2.0-incubating-SNAPSHOT.jar:2.2.0-incubating-SNAPSHOT]
   	at org.apache.pulsar.common.api.PulsarDecoder.channelRead(PulsarDecoder.java:282) ~[org.apache.pulsar-pulsar-common-2.2.0-incubating-SNAPSHOT.jar:2.2.0-incubating-SNAPSHOT]
   	at org.apache.pulsar.proxy.server.ProxyConnection.channelRead(ProxyConnection.java:164)
~[org.apache.pulsar-pulsar-proxy-2.2.0-incubating-SNAPSHOT.jar:2.2.0-incubating-SNAPSHOT]
   	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
[io.netty-netty-all-4.1.22.Final.jar:4.1.22.Final]
   	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
[io.netty-netty-all-4.1.22.Final.jar:4.1.22.Final]
   	at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
[io.netty-netty-all-4.1.22.Final.jar:4.1.22.Final]
   	at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:310)
[io.netty-netty-all-4.1.22.Final.jar:4.1.22.Final]
   	at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:284)
[io.netty-netty-all-4.1.22.Final.jar:4.1.22.Final]
   	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
[io.netty-netty-all-4.1.22.Final.jar:4.1.22.Final]
   	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
[io.netty-netty-all-4.1.22.Final.jar:4.1.22.Final]
   	at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
[io.netty-netty-all-4.1.22.Final.jar:4.1.22.Final]
   	at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1414)
[io.netty-netty-all-4.1.22.Final.jar:4.1.22.Final]
   	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
[io.netty-netty-all-4.1.22.Final.jar:4.1.22.Final]
   	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
[io.netty-netty-all-4.1.22.Final.jar:4.1.22.Final]
   	at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:945)
[io.netty-netty-all-4.1.22.Final.jar:4.1.22.Final]
   	at io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.epollInReady(AbstractEpollStreamChannel.java:806)
[io.netty-netty-all-4.1.22.Final.jar:4.1.22.Final]
   	at io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:404) [io.netty-netty-all-4.1.22.Final.jar:4.1.22.Final]
   	at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:304) [io.netty-netty-all-4.1.22.Final.jar:4.1.22.Final]
   	at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:886)
[io.netty-netty-all-4.1.22.Final.jar:4.1.22.Final]
   	at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
[io.netty-netty-all-4.1.22.Final.jar:4.1.22.Final]
   	at java.lang.Thread.run(Thread.java:748) [?:1.8.0_151]
   10:43:13.964 [pulsar-discovery-io-2-3] INFO  org.apache.pulsar.client.impl.PulsarClientImpl
- Client closing. URL: pulsar-proxy:6650
   10:43:13.965 [pulsar-discovery-io-2-3] INFO  org.apache.pulsar.proxy.server.ProxyConnectionPool
- Closing ProxyConnectionPool.
   ```
   
   #### Steps to reproduce
   
   Setup a pulsar cluster with proxy, subscribe to topics using a regex pattern.
   
   #### System configuration
   **Pulsar version**: master
   

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


With regards,
Apache Git Services

Mime
View raw message