You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by GitBox <gi...@apache.org> on 2021/07/20 17:12:11 UTC

[GitHub] [pulsar] lhotari opened a new issue #11395: Flaky-test: PersistentTopicStreamingDispatcherE2ETest.testMessageExpiryWithTopicMessageTTL

lhotari opened a new issue #11395:
URL: https://github.com/apache/pulsar/issues/11395


   PersistentTopicStreamingDispatcherE2ETest is flaky. The testMessageExpiryWithTopicMessageTTL test method fails sporadically.
   
   [example failure](https://github.com/apache/pulsar/pull/11343/checks?check_run_id=3112038013#step:10:1384)
   
   ```
   Error:  testMessageExpiryWithTopicMessageTTL(org.apache.pulsar.broker.service.persistent.PersistentTopicStreamingDispatcherE2ETest)  Time elapsed: 21.29 s  <<< FAILURE!
     java.lang.AssertionError: expected [500] but found [409]
     	at org.testng.Assert.fail(Assert.java:99)
     	at org.testng.Assert.failNotEquals(Assert.java:1037)
     	at org.testng.Assert.assertEqualsImpl(Assert.java:140)
     	at org.testng.Assert.assertEquals(Assert.java:122)
     	at org.testng.Assert.assertEquals(Assert.java:907)
     	at org.testng.Assert.assertEquals(Assert.java:917)
     	at org.apache.pulsar.broker.service.PersistentTopicE2ETest.testMessageExpiryWithTopicMessageTTL(PersistentTopicE2ETest.java:1008)
     	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
     	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
     	at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
     	at java.base/java.lang.reflect.Method.invoke(Method.java:566)
     	at org.testng.internal.MethodInvocationHelper.invokeMethod(MethodInvocationHelper.java:132)
     	at org.testng.internal.InvokeMethodRunnable.runOne(InvokeMethodRunnable.java:45)
     	at org.testng.internal.InvokeMethodRunnable.call(InvokeMethodRunnable.java:73)
     	at org.testng.internal.InvokeMethodRunnable.call(InvokeMethodRunnable.java:11)
     	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
     	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
     	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
     	at java.base/java.lang.Thread.run(Thread.java:829)
   ```
   


-- 
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: commits-unsubscribe@pulsar.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [pulsar] eolivelli closed issue #11395: Flaky-test: PersistentTopicStreamingDispatcherE2ETest.testMessageExpiryWithTopicMessageTTL

Posted by GitBox <gi...@apache.org>.
eolivelli closed issue #11395:
URL: https://github.com/apache/pulsar/issues/11395


   


-- 
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: commits-unsubscribe@pulsar.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [pulsar] Technoboy- commented on issue #11395: Flaky-test: PersistentTopicStreamingDispatcherE2ETest.testMessageExpiryWithTopicMessageTTL

Posted by GitBox <gi...@apache.org>.
Technoboy- commented on issue #11395:
URL: https://github.com/apache/pulsar/issues/11395#issuecomment-889854088


   The stack trace :
   ```
   org.apache.pulsar.client.admin.PulsarAdminException$ConflictException: Cannot delete non empty bundle
   	at org.apache.pulsar.client.admin.internal.BaseResource.getApiException(BaseResource.java:234)
   	at org.apache.pulsar.client.admin.internal.BaseResource$3.failed(BaseResource.java:184)
   	at org.glassfish.jersey.client.JerseyInvocation$1.failed(JerseyInvocation.java:882)
   	at org.glassfish.jersey.client.JerseyInvocation$1.completed(JerseyInvocation.java:863)
   	at org.glassfish.jersey.client.ClientRuntime.processResponse(ClientRuntime.java:229)
   	at org.glassfish.jersey.client.ClientRuntime.access$200(ClientRuntime.java:62)
   	at org.glassfish.jersey.client.ClientRuntime$2.lambda$response$0(ClientRuntime.java:173)
   	at org.glassfish.jersey.internal.Errors$1.call(Errors.java:248)
   	at org.glassfish.jersey.internal.Errors$1.call(Errors.java:244)
   	at org.glassfish.jersey.internal.Errors.process(Errors.java:292)
   	at org.glassfish.jersey.internal.Errors.process(Errors.java:274)
   	at org.glassfish.jersey.internal.Errors.process(Errors.java:244)
   	at org.glassfish.jersey.process.internal.RequestScope.runInScope(RequestScope.java:288)
   	at org.glassfish.jersey.client.ClientRuntime$2.response(ClientRuntime.java:173)
   	at org.apache.pulsar.client.admin.internal.http.AsyncHttpConnector.lambda$apply$1(AsyncHttpConnector.java:212)
   	at java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:859)
   	at java.base/java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:837)
   	at java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506)
   	at java.base/java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:2073)
   	at org.apache.pulsar.client.admin.internal.http.AsyncHttpConnector.lambda$retryOperation$4(AsyncHttpConnector.java:254)
   	at java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:859)
   	at java.base/java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:837)
   	at java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506)
   	at java.base/java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:2073)
   	at org.asynchttpclient.netty.NettyResponseFuture.loadContent(NettyResponseFuture.java:222)
   	at org.asynchttpclient.netty.NettyResponseFuture.done(NettyResponseFuture.java:257)
   	at org.asynchttpclient.netty.handler.AsyncHttpClientHandler.finishUpdate(AsyncHttpClientHandler.java:241)
   	at org.asynchttpclient.netty.handler.HttpHandler.handleChunk(HttpHandler.java:114)
   	at org.asynchttpclient.netty.handler.HttpHandler.handleRead(HttpHandler.java:143)
   	at org.asynchttpclient.netty.handler.AsyncHttpClientHandler.channelRead(AsyncHttpClientHandler.java:78)
   	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
   	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
   	at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357)
   	at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:103)
   	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
   	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
   	at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357)
   	at io.netty.channel.CombinedChannelDuplexHandler$DelegatingChannelHandlerContext.fireChannelRead(CombinedChannelDuplexHandler.java:436)
   	at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:324)
   	at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:296)
   	at io.netty.channel.CombinedChannelDuplexHandler.channelRead(CombinedChannelDuplexHandler.java:251)
   	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
   	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
   	at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357)
   	at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1410)
   	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
   	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
   	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:719)
   	at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:655)
   	at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:581)
   	at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:493)
   	at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:986)
   	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:834)
   Caused by: javax.ws.rs.ClientErrorException: HTTP 409 Conflict
   	at org.glassfish.jersey.client.JerseyInvocation.createExceptionForFamily(JerseyInvocation.java:985)
   	at org.glassfish.jersey.client.JerseyInvocation.convertToException(JerseyInvocation.java:967)
   	at org.glassfish.jersey.client.JerseyInvocation.access$700(JerseyInvocation.java:82)
   	... 54 more
   ```
   So the simple way to fix this test is delete namespace forcely.


-- 
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: commits-unsubscribe@pulsar.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [pulsar] lhotari commented on issue #11395: Flaky-test: PersistentTopicStreamingDispatcherE2ETest.testMessageExpiryWithTopicMessageTTL

Posted by GitBox <gi...@apache.org>.
lhotari commented on issue #11395:
URL: https://github.com/apache/pulsar/issues/11395#issuecomment-884680814


   [another one](https://github.com/apache/pulsar/pull/11343/checks?check_run_id=3130775265#step:10:2177):
   ```
    Error:  Tests run: 69, Failures: 1, Errors: 0, Skipped: 51, Time elapsed: 110.913 s <<< FAILURE! - in org.apache.pulsar.broker.service.PersistentTopicE2ETest
     Error:  testMessageExpiryWithTopicMessageTTL(org.apache.pulsar.broker.service.PersistentTopicE2ETest)  Time elapsed: 20.851 s  <<< FAILURE!
     java.lang.AssertionError: expected [500] but found [409]
     	at org.testng.Assert.fail(Assert.java:99)
     	at org.testng.Assert.failNotEquals(Assert.java:1037)
     	at org.testng.Assert.assertEqualsImpl(Assert.java:140)
     	at org.testng.Assert.assertEquals(Assert.java:122)
     	at org.testng.Assert.assertEquals(Assert.java:907)
     	at org.testng.Assert.assertEquals(Assert.java:917)
     	at org.apache.pulsar.broker.service.PersistentTopicE2ETest.testMessageExpiryWithTopicMessageTTL(PersistentTopicE2ETest.java:1008)
     	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
     	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
     	at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
     	at java.base/java.lang.reflect.Method.invoke(Method.java:566)
     	at org.testng.internal.MethodInvocationHelper.invokeMethod(MethodInvocationHelper.java:132)
     	at org.testng.internal.InvokeMethodRunnable.runOne(InvokeMethodRunnable.java:45)
     	at org.testng.internal.InvokeMethodRunnable.call(InvokeMethodRunnable.java:73)
     	at org.testng.internal.InvokeMethodRunnable.call(InvokeMethodRunnable.java:11)
     	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
     	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
     	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
     	at java.base/java.lang.Thread.run(Thread.java:829)
   ```


-- 
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: commits-unsubscribe@pulsar.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org