[ https://issues.apache.org/jira/browse/BOOKKEEPER-539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13548812#comment-13548812 ]
Sijie Guo commented on BOOKKEEPER-539: -------------------------------------- I would prefer that [~jiannan] could verify it to ensure that BOOKKEEPER-529 did resolve this issue, since this issue found when he ran the tests. Actually, I could not reproduce that issue on my mac. > ClientNotSubscribedException & doesn't receive enough messages in > TestThrottlingDelivery#testServerSideThrottle > --------------------------------------------------------------------------------------------------------------- > > Key: BOOKKEEPER-539 > URL: https://issues.apache.org/jira/browse/BOOKKEEPER-539 > Project: Bookkeeper > Issue Type: Bug > Components: hedwig-server > Reporter: Sijie Guo > Assignee: Sijie Guo > Priority: Blocker > Fix For: 4.2.0 > > Attachments: > org.apache.hedwig.server.delivery.TestThrottlingDelivery-output.txt, > org.apache.hedwig.server.delivery.TestThrottlingDelivery-output.txt > > > ClientNotSubscribedException & doesn't receive enough messages failure in > TestThrottlingDelivery#testServerSideThrottle. > {code} > ------------------------------------------------------------------------------- > Test set: org.apache.hedwig.server.delivery.TestThrottlingDelivery > ------------------------------------------------------------------------------- > Tests run: 2, Failures: 1, Errors: 0, Skipped: 0, Time elapsed: 18.544 sec > <<< FAILURE! > testServerSideThrottle[1](org.apache.hedwig.server.delivery.TestThrottlingDelivery) > Time elapsed: 6.776 sec <<< FAILURE! > junit.framework.AssertionFailedError: Should be expected messages with only 6 > expected:<6> but was:<2> > at junit.framework.Assert.fail(Assert.java:47) > at junit.framework.Assert.failNotEquals(Assert.java:283) > at junit.framework.Assert.assertEquals(Assert.java:64) > at junit.framework.Assert.assertEquals(Assert.java:195) > at > org.apache.hedwig.server.delivery.TestThrottlingDelivery.throttleX(TestThrottlingDelivery.java:151) > at > org.apache.hedwig.server.delivery.TestThrottlingDelivery.testServerSideThrottle(TestThrottlingDelivery.java:216) > at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) > at > sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57) > at > sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) > at java.lang.reflect.Method.invoke(Method.java:601) > at > org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:44) > at > org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:15) > at > org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:41) > at > org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:20) > at > org.junit.internal.runners.statements.FailOnTimeout$1.run(FailOnTimeout.java:28) > {code} > {code} > ------------------------------------------------------------------------------- > Test set: org.apache.hedwig.server.delivery.TestThrottlingDelivery > ------------------------------------------------------------------------------- > Tests run: 2, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 18.294 sec > <<< FAILURE! > testServerSideThrottle[1](org.apache.hedwig.server.delivery.TestThrottlingDelivery) > Time elapsed: 6.763 sec <<< ERROR! > org.apache.hedwig.exceptions.PubSubException$ClientNotSubscribedException: > Client is not yet subscribed to Topic: > testServerSideThrottleWithHigherValue, SubscriberId: serverThrottleSub > at > org.apache.hedwig.client.netty.impl.multiplex.MultiplexHChannelManager.startDelivery(MultiplexHChannelManager. > java:221) > at > org.apache.hedwig.client.netty.impl.multiplex.MultiplexHChannelManager.startDelivery(MultiplexHChannelManager. > java:199) > at > org.apache.hedwig.client.netty.HedwigSubscriber.startDelivery(HedwigSubscriber.java:358) > at > org.apache.hedwig.server.delivery.TestThrottlingDelivery.throttleX(TestThrottlingDelivery.java:113) > at > org.apache.hedwig.server.delivery.TestThrottlingDelivery.testServerSideThrottle(TestThrottlingDelivery.java:226) > at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) > at > sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57) > at > sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) > at java.lang.reflect.Method.invoke(Method.java:601) > at > org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:44) > at > org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:15) > at > org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:41) > at > org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:20) > at > org.junit.internal.runners.statements.FailOnTimeout$1.run(FailOnTimeout.java:28) > {code} -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira