Uploaded image for project: 'Nuxeo Platform'
  1. Nuxeo Platform
  2. NXP-25291

Fix Regression on TestLogStreamProcessorChronicle.testComplexTopoManyRecords

    XMLWordPrintable

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Minor
    • Resolution: Fixed
    • Affects Version/s: 10.2-SNAPSHOT
    • Fix Version/s: 10.2
    • Component/s: Streams

      Description

      Seen after CQ upgrade NXP-25231

      org.nuxeo.lib.stream.tests.computation.TestLogStreamProcessorChronicle.testComplexTopoManyRecords
      Failing for the past 1 build (Since Unstable#816 )
      Took 16 sec.
      add description
      Error Message
      
      expected:<24072> but was:<22618>
      
      Stacktrace
      
      java.lang.AssertionError: expected:<24072> but was:<22618>
      	at org.junit.Assert.fail(Assert.java:88)
      	at org.junit.Assert.failNotEquals(Assert.java:834)
      	at org.junit.Assert.assertEquals(Assert.java:645)
      	at org.junit.Assert.assertEquals(Assert.java:631)
      	at org.nuxeo.lib.stream.tests.computation.TestStreamProcessor.testComplexTopo(TestStreamProcessor.java:243)
      	at org.nuxeo.lib.stream.tests.computation.TestStreamProcessor.testComplexTopoManyRecords(TestStreamProcessor.java:279)
      
      
      Standard Output
      
      05:30:14,761 [C1Pool-10,in:4,inCheckpoint:3,out:3,lastRead:1530509414636,lastTimer:0,wm:200606929809047553,loop:3,record] ERROR [ComputationRunner] C1: CHECKPOINT FAILURE: Resume may create duplicates.
      05:30:14,762 [C1Pool-10,in:4,inCheckpoint:3,out:3,lastRead:1530509414636,lastTimer:0,wm:200606929809047553,loop:3,record] ERROR [ComputationRunner] C1: Exception in processLoop: Released
      java.lang.IllegalStateException: Released
      	at net.openhft.chronicle.core.ReferenceCounter.reserve(ReferenceCounter.java:56)
      	at net.openhft.chronicle.bytes.MappedFile.reserve(MappedFile.java:352)
      	at net.openhft.chronicle.bytes.MappedBytes.reserve(MappedBytes.java:71)
      	at net.openhft.chronicle.bytes.MappedBytes.<init>(MappedBytes.java:63)
      	at net.openhft.chronicle.bytes.MappedBytes.<init>(MappedBytes.java:56)
      	at net.openhft.chronicle.bytes.MappedBytes.mappedBytes(MappedBytes.java:199)
      	at net.openhft.chronicle.queue.impl.single.ReferenceCountedCache.get(ReferenceCountedCache.java:44)
      	at net.openhft.chronicle.queue.impl.single.SingleChronicleQueue$StoreSupplier.acquire(SingleChronicleQueue.java:813)
      	at net.openhft.chronicle.queue.impl.WireStorePool.acquire(WireStorePool.java:98)
      	at net.openhft.chronicle.queue.impl.single.SingleChronicleQueueExcerpts$StoreAppender.setCycle2(SingleChronicleQueueExcerpts.java:244)
      	at net.openhft.chronicle.queue.impl.single.SingleChronicleQueueExcerpts$StoreAppender.writingDocument(SingleChronicleQueueExcerpts.java:314)
      	at net.openhft.chronicle.wire.MarshallableOut.writeDocument(MarshallableOut.java:95)
      	at org.nuxeo.lib.stream.log.chronicle.ChronicleLogAppender.append(ChronicleLogAppender.java:195)
      	at org.nuxeo.lib.stream.log.LogAppender.append(LogAppender.java:62)
      	at org.nuxeo.lib.stream.computation.log.ComputationRunner.sendRecords(ComputationRunner.java:366)
      	at org.nuxeo.lib.stream.computation.log.ComputationRunner.checkpoint(ComputationRunner.java:333)
      	at org.nuxeo.lib.stream.computation.log.ComputationRunner.checkpointIfNecessary(ComputationRunner.java:321)
      	at org.nuxeo.lib.stream.computation.log.ComputationRunner.processRecord(ComputationRunner.java:288)
      	at org.nuxeo.lib.stream.computation.log.ComputationRunner.processLoop(ComputationRunner.java:194)
      	at org.nuxeo.lib.stream.computation.log.ComputationRunner.run(ComputationRunner.java:152)
      	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)
      
      Standard Error
      
      java.lang.Throwable: 60fabe32-C1Pool-04,in:2,inCheckpoint:1,out:1,lastRead:1530509414286,lastTimer:0,wm:200606929790828545,loop:1,record creation ref-count=1
      	at net.openhft.chronicle.core.ReferenceCounter.newRefCountHistory(ReferenceCounter.java:45)
      	at net.openhft.chronicle.core.ReferenceCounter.<init>(ReferenceCounter.java:35)
      	at net.openhft.chronicle.core.ReferenceCounter.onReleased(ReferenceCounter.java:40)
      	at net.openhft.chronicle.bytes.MappedFile.<init>(MappedFile.java:57)
      	at net.openhft.chronicle.bytes.MappedFile.of(MappedFile.java:136)
      	at net.openhft.chronicle.queue.impl.single.SingleChronicleQueue.mappedFile(SingleChronicleQueue.java:698)
      	at net.openhft.chronicle.queue.impl.single.SingleChronicleQueue.access$1300(SingleChronicleQueue.java:60)
      	at net.openhft.chronicle.queue.impl.single.SingleChronicleQueue$StoreSupplier.lambda$new$0(SingleChronicleQueue.java:783)
      	at net.openhft.chronicle.queue.impl.single.ReferenceCountedCache.get(ReferenceCountedCache.java:38)
      	at net.openhft.chronicle.queue.impl.single.SingleChronicleQueue$StoreSupplier.acquire(SingleChronicleQueue.java:813)
      	at net.openhft.chronicle.queue.impl.WireStorePool.acquire(WireStorePool.java:98)
      	at net.openhft.chronicle.queue.impl.single.SingleChronicleQueueExcerpts$StoreAppender.setCycle2(SingleChronicleQueueExcerpts.java:244)
      	at net.openhft.chronicle.queue.impl.single.SingleChronicleQueueExcerpts$StoreAppender.writingDocument(SingleChronicleQueueExcerpts.java:314)
      	at net.openhft.chronicle.wire.MarshallableOut.writeDocument(MarshallableOut.java:95)
      	at org.nuxeo.lib.stream.log.chronicle.ChronicleLogAppender.append(ChronicleLogAppender.java:195)
      	at org.nuxeo.lib.stream.log.LogAppender.append(LogAppender.java:62)
      	at org.nuxeo.lib.stream.computation.log.ComputationRunner.sendRecords(ComputationRunner.java:366)
      	at org.nuxeo.lib.stream.computation.log.ComputationRunner.checkpoint(ComputationRunner.java:333)
      	at org.nuxeo.lib.stream.computation.log.ComputationRunner.checkpointIfNecessary(ComputationRunner.java:321)
      	at org.nuxeo.lib.stream.computation.log.ComputationRunner.processRecord(ComputationRunner.java:288)
      	at org.nuxeo.lib.stream.computation.log.ComputationRunner.processLoop(ComputationRunner.java:194)
      	at org.nuxeo.lib.stream.computation.log.ComputationRunner.run(ComputationRunner.java:152)
      	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)
      java.lang.Throwable: 60fabe32-C1Pool-04,in:2,inCheckpoint:1,out:1,lastRead:1530509414286,lastTimer:0,wm:200606929790828545,loop:1,record Reserve ref-count=2
      	at net.openhft.chronicle.core.ReferenceCounter.recordResevation(ReferenceCounter.java:66)
      	at net.openhft.chronicle.core.ReferenceCounter.reserve(ReferenceCounter.java:59)
      	at net.openhft.chronicle.bytes.MappedFile.reserve(MappedFile.java:352)
      	at net.openhft.chronicle.bytes.MappedBytes.reserve(MappedBytes.java:71)
      	at net.openhft.chronicle.bytes.MappedBytes.<init>(MappedBytes.java:63)
      	at net.openhft.chronicle.bytes.MappedBytes.<init>(MappedBytes.java:56)
      	at net.openhft.chronicle.bytes.MappedBytes.mappedBytes(MappedBytes.java:199)
      	at net.openhft.chronicle.queue.impl.single.ReferenceCountedCache.get(ReferenceCountedCache.java:44)
      	at net.openhft.chronicle.queue.impl.single.SingleChronicleQueue$StoreSupplier.acquire(SingleChronicleQueue.java:813)
      	at net.openhft.chronicle.queue.impl.WireStorePool.acquire(WireStorePool.java:98)
      	at net.openhft.chronicle.queue.impl.single.SingleChronicleQueueExcerpts$StoreAppender.setCycle2(SingleChronicleQueueExcerpts.java:244)
      	at net.openhft.chronicle.queue.impl.single.SingleChronicleQueueExcerpts$StoreAppender.writingDocument(SingleChronicleQueueExcerpts.java:314)
      	at net.openhft.chronicle.wire.MarshallableOut.writeDocument(MarshallableOut.java:95)
      	at org.nuxeo.lib.stream.log.chronicle.ChronicleLogAppender.append(ChronicleLogAppender.java:195)
      
      

      https://qa.nuxeo.org/jenkins/job/master/job/nuxeo-master-fullbuild-part1-multidb/Slave=MULTIDB_LINUX,dbprofile=mariadb,jdk=java-8-openjdk/816/

        Attachments

          Issue Links

            Activity

              People

              • Votes:
                0 Vote for this issue
                Watchers:
                3 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved:

                  Time Tracking

                  Estimated:
                  Original Estimate - Not Specified
                  Not Specified
                  Remaining:
                  Remaining Estimate - 0 minutes
                  0m
                  Logged:
                  Time Spent - 1 day
                  1d