Flaky-test: SimpleIntegrationTest.testConsumerDisconnectNotMissingMessage

Open

#1,044 opened on Jul 27, 2023 0 comments 0 reactions 0 assignees View on GitHub

Nobody has claimed this yet.

Assessment

Difficulty: 4/5
Estimated time: 3-5 days
Newbie friendliness: 35/100

Issue type: Bug
Clarity: Mostly clear
Activity status: Stale
Tech stack: java
Domain: distributed-systems, testing-qa

Research direction

Start with SimpleIntegrationTest.testConsumerDisconnectNotMissingMessage at line 476 and reproduce the failure from the reported integration-test run. Trace why the assertion receives 400 instead of 1000; done means the test passes reliably without intermittently missing messages.

Written by the indexing model from the issue text.

Description

Error:  Tests run: 51, Failures: 2, Errors: 0, Skipped: 0, Time elapsed: 339.788 s <<< FAILURE! - in io.streamnative.pulsar.handlers.mqtt.mqtt3.fusesource.base.SimpleIntegrationTest
Error:  testConsumerDisconnectNotMissingMessage(io.streamnative.pulsar.handlers.mqtt.mqtt3.fusesource.base.SimpleIntegrationTest)  Time elapsed: 300.925 s  <<< FAILURE!
java.lang.AssertionError: expected [1000] but found [400]
	at org.testng.Assert.fail(Assert.java:96)
	at org.testng.Assert.failNotEquals(Assert.java:776)
	at org.testng.Assert.assertEqualsImpl(Assert.java:137)
	at org.testng.Assert.assertEquals(Assert.java:[118](https://github.com/streamnative/mop/actions/runs/5675850046/job/15381703781?pr=1040#step:6:119))
	at org.testng.Assert.assertEquals(Assert.java:652)
	at org.testng.Assert.assertEquals(Assert.java:662)
	at io.streamnative.pulsar.handlers.mqtt.mqtt3.fusesource.base.SimpleIntegrationTest.testConsumerDisconnectNotMissingMessage(SimpleIntegrationTest.java:476)
	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
	at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.base/java.lang.reflect.Method.invoke(Method.java:568)

Dominant language: Java
Stars: 190
Forks: 56
Avg merge: 27m
Merged PRs (30d): 1

Contributor guide

No contributing guide indexed for this repository

First steps

Read the whole issue, then the project's contributing guide.
Comment on the issue to say you are picking it up — it saves two people doing the same work.
Fork the repository and make your change on a branch.
Open a pull request that references the issue number.

Similar issues

[Bug] [Connector-V2] [Http] A streaming Http source never completes a checkpoint: poll_interval_millis is waited out holding the checkpoint lock Open

Difficulty 2/5 1-3 hours Newbie friendliness 78/100

apache/seatunnel#12411 · Opened Sep 20, 2026
wafv2: TagResource/UntagResource don't enforce the 50-tag limit or key/value length limits Open

Difficulty 2/5 1-3 hours Newbie friendliness 76/100

floci-io/floci#4035 · Opened Sep 20, 2026
[Bug]: 26.3 Missing directional_particles in ConsumeEffect Open

bug needs triage

Difficulty 2/5 1-3 hours Newbie friendliness 76/100

Minestom/Minestom#3375 · Opened Sep 20, 2026
The `grepIn` javadoc example never matches real XMIR, so a user who copies it silently gets no optimization Open

Difficulty 1/5 Under an hour Newbie friendliness 94/100

objectionary/hone-maven-plugin#1061 · Opened Sep 20, 2026
Flaky test: TestLucene104ScalarQuantizedVectorsFormat.testDataBlindNoRawFloatVectors fails when segments > 1 Open

type:bug

Difficulty 2/5 1-3 hours Newbie friendliness 72/100

apache/lucene#16692 · Opened Sep 20, 2026

More Java issues