huangdx0726 commented on issue #5716: [Issues 5709]remove the namespace checking URL: https://github.com/apache/pulsar/pull/5716#issuecomment-563066542 > > > @huangdx0726 to take a look > > ``` > 2019-12-09\T\02:44:28.726 [ERROR] multiTopicsInDifferentNameSpace(org.apache.pulsar.client.impl.MultiTopicsConsumerImplTest) Time elapsed: 0.028 s <<< FAILURE! > org.apache.pulsar.client.api.PulsarClientException: java.util.concurrent.ExecutionException: org.apache.pulsar.client.api.PulsarClientException: java.util.concurrent.CompletionException: io.netty.channel.AbstractChannel$AnnotatedConnectException: Connection refused: localhost/127.0.0.1:6650 > at org.apache.pulsar.client.api.PulsarClientException.unwrap(PulsarClientException.java:647) > at org.apache.pulsar.client.impl.ProducerBuilderImpl.create(ProducerBuilderImpl.java:90) > at org.apache.pulsar.client.impl.MultiTopicsConsumerImplTest.multiTopicsInDifferentNameSpace(MultiTopicsConsumerImplTest.java:96) > at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) > at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) > at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) > at java.lang.reflect.Method.invoke(Method.java:498) > at org.testng.internal.MethodInvocationHelper.invokeMethod(MethodInvocationHelper.java:124) > at org.testng.internal.InvokeMethodRunnable.runOne(InvokeMethodRunnable.java:54) > at org.testng.internal.InvokeMethodRunnable.run(InvokeMethodRunnable.java:44) > at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) > at java.util.concurrent.FutureTask.run(FutureTask.java:266) > at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) > at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) > at java.lang.Thread.run(Thread.java:748) > Caused by: java.util.concurrent.ExecutionException: org.apache.pulsar.client.api.PulsarClientException: java.util.concurrent.CompletionException: io.netty.channel.AbstractChannel$AnnotatedConnectException: Connection refused: localhost/127.0.0.1:6650 > at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357) > at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1895) > at org.apache.pulsar.client.impl.ProducerBuilderImpl.create(ProducerBuilderImpl.java:88) > ... 13 more > Caused by: org.apache.pulsar.client.api.PulsarClientException: java.util.concurrent.CompletionException: io.netty.channel.AbstractChannel$AnnotatedConnectException: Connection refused: localhost/127.0.0.1:6650 > at org.apache.pulsar.client.impl.ConnectionPool.lambda$null$9(ConnectionPool.java:203) > at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:163) > at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:510) > at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:518) > at io.netty.util.concurrent.SingleThreadEventExecutor$6.run(SingleThreadEventExecutor.java:1050) > at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) > at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) > ... 1 more > Caused by: java.util.concurrent.CompletionException: io.netty.channel.AbstractChannel$AnnotatedConnectException: Connection refused: localhost/127.0.0.1:6650 > at java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292) > at java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308) > at java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:647) > at java.util.concurrent.CompletableFuture$UniAccept.tryFire(CompletableFuture.java:632) > at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474) > at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977) > at org.apache.pulsar.client.impl.ConnectionPool.lambda$connectToAddress$17(ConnectionPool.java:276) > at io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:577) > at io.netty.util.concurrent.DefaultPromise.notifyListeners0(DefaultPromise.java:570) > at io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:549) > at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:490) > at io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:615) > at io.netty.util.concurrent.DefaultPromise.setFailure0(DefaultPromise.java:608) > at io.netty.util.concurrent.DefaultPromise.tryFailure(DefaultPromise.java:117) > at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.fulfillConnectPromise(AbstractNioChannel.java:321) > at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:337) > at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:688) > at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:635) > at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:552) > at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:514) > ... 4 more > Caused by: io.netty.channel.AbstractChannel$AnnotatedConnectException: Connection refused: localhost/127.0.0.1:6650 > Caused by: java.net.ConnectException: Connection refused > at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) > at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717) > at io.netty.channel.socket.nio.NioSocketChannel.doFinishConnect(NioSocketChannel.java:330) > at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:334) > at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:688) > at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:635) > at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:552) > at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:514) > at io.netty.util.concurrent.SingleThreadEventExecutor$6.run(SingleThreadEventExecutor.java:1050) > at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) > at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) > at java.lang.Thread.run(Thread.java:748) > ``` pulsar Service not started？
---------------------------------------------------------------- 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
