Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Intermittent test failure int KeySharedSubscriptionTest.testConsumerCrashSendAndReceiveWithHashRangeStickyKeyConsumerSelector #4353

Closed
merlimat opened this issue May 23, 2019 · 4 comments

Comments

@merlimat
Copy link
Contributor

https://builds.apache.org/job/pulsar_precommit_java8/9152/testReport/junit/org.apache.pulsar.client.api/KeySharedSubscriptionTest/testConsumerCrashSendAndReceiveWithHashRangeStickyKeyConsumerSelector/

org.apache.pulsar.client.api.KeySharedSubscriptionTest.testConsumerCrashSendAndReceiveWithHashRangeStickyKeyConsumerSelector

Failing for the past 1 build (Since Failed#9152 )
Took 5 min 0 sec.
add description
Error Message
Method org.apache.pulsar.client.api.KeySharedSubscriptionTest.testConsumerCrashSendAndReceiveWithHashRangeStickyKeyConsumerSelector() didn't finish within the time-out 300000
Stacktrace
org.testng.internal.thread.ThreadTimeoutException: Method org.apache.pulsar.client.api.KeySharedSubscriptionTest.testConsumerCrashSendAndReceiveWithHashRangeStickyKeyConsumerSelector() didn't finish within the time-out 300000
	at java.util.concurrent.locks.ReentrantLock.unlock(ReentrantLock.java:457)
	at org.apache.pulsar.common.util.collections.GrowableArrayBlockingQueue.take(GrowableArrayBlockingQueue.java:191)
	at org.apache.pulsar.client.impl.ConsumerImpl.internalReceive(ConsumerImpl.java:312)
	at org.apache.pulsar.client.impl.ConsumerBase.receive(ConsumerBase.java:108)
	at org.apache.pulsar.client.api.KeySharedSubscriptionTest.testConsumerCrashSendAndReceiveWithHashRangeStickyKeyConsumerSelector(KeySharedSubscriptionTest.java:238)
	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)

cc/ @codelipenghui

@jiazhai
Copy link
Member

jiazhai commented May 24, 2019

According to the time line, Seems this is related to changes in #4329 ?

@jiazhai
Copy link
Member

jiazhai commented May 24, 2019

@codelipenghui Hi Penghui is this the fix?
9b5f749

@merlimat
Copy link
Contributor Author

Yes, the pending acks needs to be filled in from the same thread, instead of doing that from the consumer connection thread.

@merlimat
Copy link
Contributor Author

s

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Development

No branches or pull requests

2 participants