pubsublite.cloudpubsub.internal.AssigningSubscriberTest: assignerErrorFailsSubs failed

[flaky-bot]

This test failed!

To configure my behavior, see the Flaky Bot documentation.

If I'm commenting on this issue too often, add the flakybot: quiet label and
I will stop commenting.

---

commit: 50fbb22
buildURL: Build Status, Sponge
status: failed

Test output

Wanted but not invoked:
fakeSubscriber.awaitTerminated();
-> at com.google.cloud.pubsublite.cloudpubsub.internal.AssigningSubscriberTest.assignerErrorFailsSubs(AssigningSubscriberTest.java:212)
However, there were exactly 4 interactions with this mock:

fakeSubscriber.addListener(

Mock for Listener, hashCode: 462507574,

java.util.concurrent.ThreadPoolExecutor@29f3ea39[Running, pool size = 3, active threads = 0, queued tasks = 0, completed tasks = 34]

);

-> at com.google.cloud.pubsublite.internal.testing.RetryingConnectionHelpers.whenTerminated(RetryingConnectionHelpers.java:61)
fakeSubscriber.stopAsync();

-> at com.google.cloud.pubsublite.internal.wire.ApiServiceUtils.blockingShutdown(ApiServiceUtils.java:71)
fakeSubscriber.doStop();

-> at com.google.api.core.AbstractApiService$InnerService.doStop(AbstractApiService.java:152)
fakeSubscriber.notifyStopped();

-> at com.google.cloud.pubsublite.internal.testing.FakeApiService.doStop(FakeApiService.java:41)
at com.google.cloud.pubsublite.cloudpubsub.internal.AssigningSubscriberTest.assignerErrorFailsSubs(AssigningSubscriberTest.java:212)
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.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
at org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63)
at org.junit.runners.ParentRunner$4.run(ParentRunner.java:331)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329)
at org.junit.runners.ParentRunner.access$100(ParentRunner.java:66)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293)
at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
at org.junit.runners.ParentRunner.run(ParentRunner.java:413)
at org.junit.runners.Suite.runChild(Suite.java:128)
at org.junit.runners.Suite.runChild(Suite.java:27)
at org.junit.runners.ParentRunner$4.run(ParentRunner.java:331)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329)
at org.junit.runners.ParentRunner.access$100(ParentRunner.java:66)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293)
at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
at org.junit.runners.ParentRunner.run(ParentRunner.java:413)
at org.apache.maven.surefire.junitcore.JUnitCore.run(JUnitCore.java:55)
at org.apache.maven.surefire.junitcore.JUnitCoreWrapper.createRequestAndRun(JUnitCoreWrapper.java:137)
at org.apache.maven.surefire.junitcore.JUnitCoreWrapper.executeEager(JUnitCoreWrapper.java:107)
at org.apache.maven.surefire.junitcore.JUnitCoreWrapper.execute(JUnitCoreWrapper.java:83)
at org.apache.maven.surefire.junitcore.JUnitCoreWrapper.execute(JUnitCoreWrapper.java:75)
at org.apache.maven.surefire.junitcore.JUnitCoreProvider.invoke(JUnitCoreProvider.java:158)
at org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:456)
at org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:169)
at org.apache.maven.surefire.booter.ForkedBooter.run(ForkedBooter.java:595)
at org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:581)

[flaky-bot]

Looks like this issue is flaky. 😟

I'm going to leave this open and stop commenting.

A human should fix and close this.

---

When run at the same commit (50fbb22), this test passed in one build (Build Status, Sponge) and failed in another build (Build Status, Sponge).

[zhumin8]

observed this again in https://github.com/googleapis/java-pubsublite/actions/runs/15397011370/job/43408276329?pr=1863

Error:    AssigningSubscriberTest.assignerErrorFailsSubs:212 
Wanted but not invoked:
fakeSubscriber.awaitTerminated();
-> at com.google.cloud.pubsublite.cloudpubsub.internal.AssigningSubscriberTest.assignerErrorFailsSubs(AssigningSubscriberTest.java:212)

However, there were exactly 4 interactions with this mock:
fakeSubscriber.addListener(
    Mock for Listener, hashCode: 1328036751,
    java.util.concurrent.ThreadPoolExecutor@1f953e51[Running, pool size = 6, active threads = 0, queued tasks = 0, completed tasks = 181]
);

[zhumin8]

Another occurrence: https://github.com/googleapis/java-pubsublite/actions/runs/15493062679/job/43623010683?pr=1872

[zhumin8]

another: https://github.com/googleapis/java-pubsublite/actions/runs/15493014635/job/43622853553

[zhumin8]

Seen again: https://github.com/googleapis/sdk-platform-java/actions/runs/16730322519/job/47356558339?pr=3876

[zhumin8]

This issue is observed several time in this generation PR:
#1901

sample log for failures:
https://github.com/googleapis/java-pubsublite/actions/runs/16739268513/job/47384194927
https://github.com/googleapis/java-pubsublite/actions/runs/16793808030/job/47560358068?pr=1901