[infinispan-issues] [JBoss JIRA] (ISPN-10991) DistributedStreamTest.testObjFlatMapIterator[DIST_SYNC, tx=false] random failures

[Will Burns (Jira)]

    [ https://issues.redhat.com/browse/ISPN-10991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13964797#comment-13964797 ] 

Will Burns commented on ISPN-10991:
-----------------------------------

I was able to track this down. The problem is when we do additional response merging, it doesn't take into account additional values.

https://github.com/infinispan/infinispan/blob/master/core/src/main/java/org/infinispan/reactive/publisher/impl/PublisherHandler.java#L361

The above method doesn't take into account having a KeyPublisherResponse which can have some extra responses.

> DistributedStreamTest.testObjFlatMapIterator[DIST_SYNC, tx=false] random failures
> ---------------------------------------------------------------------------------
>
>                 Key: ISPN-10991
>                 URL: https://issues.redhat.com/browse/ISPN-10991
>             Project: Infinispan
>          Issue Type: Bug
>          Components: Core, Test Suite
>    Affects Versions: 10.1.0.Beta1
>            Reporter: Dan Berindei
>            Assignee: Will Burns
>            Priority: Major
>              Labels: testsuite_stability
>         Attachments: ISPN-6494_bundler_20191126-1029_DistributedStreamTest-infinispan-core.log.gz, ISPN-6494_bundler_20191126-1029_ScatteredStreamIteratorTest-infinispan-core.log.gz
>
>
> {noformat}
> 01:04:14,841 ERROR (testng-Test:[]) [TestSuiteProgress] Test failed: org.infinispan.stream.DistributedStreamTest.testObjFlatMapIterator[DIST_SYNC, tx=false]
> java.lang.AssertionError: expected:<309> but was:<307>
> 	at org.testng.AssertJUnit.fail(AssertJUnit.java:59) ~[testng-6.14.3.jar:?]
> 	at org.testng.AssertJUnit.failNotEquals(AssertJUnit.java:364) ~[testng-6.14.3.jar:?]
> 	at org.testng.AssertJUnit.assertEquals(AssertJUnit.java:80) ~[testng-6.14.3.jar:?]
> 	at org.testng.AssertJUnit.assertEquals(AssertJUnit.java:245) ~[testng-6.14.3.jar:?]
> 	at org.testng.AssertJUnit.assertEquals(AssertJUnit.java:252) ~[testng-6.14.3.jar:?]
> 	at org.infinispan.stream.BaseStreamTest.testObjFlatMapIterator(BaseStreamTest.java:667) ~[test-classes/:?]
> {noformat}
> Other tests extending {{BaseStreamTest}} have similar failures:
> https://ci.infinispan.org/job/Infinispan/job/master/1625/testReport/junit/org.infinispan.stream/DistributedSequentialStreamTest/testObjFlatMapIterator_DIST_SYNC__tx_false_/
> https://ci.infinispan.org/job/Infinispan/job/master/1623/testReport/junit/org.infinispan.stream/DistributedParallelStreamTest/testObjFlatMapIterator_DIST_SYNC__tx_false_/
> https://ci.infinispan.org/job/Infinispan/job/master/1622/testReport/junit/org.infinispan.stream/DistributedStreamOffHeapTest/testObjFlatMapIterator_DIST_SYNC__tx_false_/



--
This message was sent by Atlassian Jira
(v7.13.8#713008)