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

Fix random failure on TestComputationManager.testStopAndResume

    XMLWordPrintable

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Minor
    • Resolution: Fixed
    • Affects Version/s: 9.2-SNAPSHOT
    • Fix Version/s: 9.2
    • Component/s: Events / Works

      Description

      See https://qa.nuxeo.org/jenkins/job/master/job/nuxeo-master-fullbuild-daily/333/testReport/junit/org.nuxeo.ecm.platform.importer.mqueues.tests.computation/TestComputationManager/testStopAndResume/ and https://qa.nuxeo.org/jenkins/job/master/job/nuxeo-master-fullbuild-daily/335/testReport/junit/org.nuxeo.ecm.platform.importer.mqueues.tests.computation/TestComputationManager/testStopAndResume/

      generated :32032 in 0.61s, throughput: 52511.48 records/s
      RESUME 
      KILL
      19:00:48,005 [COUNTERPool-00] ERROR [ComputationRunner] COUNTERCHECKPOINT FAILURE: resume may create duplicates
      19:00:48,009 [COUNTERPool-00] ERROR [ComputationRunner] COUNTER: null
      java.nio.BufferOverflowException
      	at net.openhft.chronicle.bytes.MappedBytes.acquireNextByteStore(MappedBytes.java:178)
      	at net.openhft.chronicle.bytes.MappedBytes.writeCheckOffset(MappedBytes.java:161)
      	at net.openhft.chronicle.bytes.AbstractBytes.compareAndSwapInt(AbstractBytes.java:165)
      	at net.openhft.chronicle.wire.AbstractWire.writeFirstHeader(AbstractWire.java:414)
      	at net.openhft.chronicle.queue.impl.single.SingleChronicleQueue$StoreSupplier.acquire(SingleChronicleQueue.java:580)
      	at net.openhft.chronicle.queue.impl.WireStorePool.acquire(WireStorePool.java:69)
      	at net.openhft.chronicle.queue.impl.single.SingleChronicleQueue.storeForCycle(SingleChronicleQueue.java:296)
      	at net.openhft.chronicle.queue.impl.single.SingleChronicleQueueExcerpts$StoreAppender.setCycle2(SingleChronicleQueueExcerpts.java:207)
      	at net.openhft.chronicle.queue.impl.single.SingleChronicleQueueExcerpts$StoreAppender.rollCycleTo(SingleChronicleQueueExcerpts.java:582)
      	at net.openhft.chronicle.queue.impl.single.SingleChronicleQueueExcerpts$StoreAppender.writingDocument(SingleChronicleQueueExcerpts.java:278)
      	at net.openhft.chronicle.queue.impl.single.SingleChronicleQueueExcerpts$StoreAppender.writeBytes(SingleChronicleQueueExcerpts.java:118)
      	at org.nuxeo.ecm.platform.importer.mqueues.mqueues.CQOffsetTracker.commit(CQOffsetTracker.java:78)
      	at org.nuxeo.ecm.platform.importer.mqueues.mqueues.CQTailer.commit(CQTailer.java:116)
      	at org.nuxeo.ecm.platform.importer.mqueues.computation.internals.mq.StreamTailerMQ.commit(StreamTailerMQ.java:73)
      	at org.nuxeo.ecm.platform.importer.mqueues.computation.internals.ComputationRunner.saveOffsets(ComputationRunner.java:241)
      	at org.nuxeo.ecm.platform.importer.mqueues.computation.internals.ComputationRunner.checkpointIfNecessary(ComputationRunner.java:218)
      	at org.nuxeo.ecm.platform.importer.mqueues.computation.internals.ComputationRunner.processTimer(ComputationRunner.java:159)
      	at org.nuxeo.ecm.platform.importer.mqueues.computation.internals.ComputationRunner.processLoop(ComputationRunner.java:113)
      	at org.nuxeo.ecm.platform.importer.mqueues.computation.internals.ComputationRunner.run(ComputationRunner.java:93)
      	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:1142)
      	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
      	at java.lang.Thread.run(Thread.java:745)
      Caused by: java.nio.channels.ClosedByInterruptException
      	at java.nio.channels.spi.AbstractInterruptibleChannel.end(AbstractInterruptibleChannel.java:202)
      	at sun.nio.ch.FileChannelImpl.size(FileChannelImpl.java:315)
      	at net.openhft.chronicle.bytes.MappedFile.acquireByteStore(MappedFile.java:198)
      	at net.openhft.chronicle.bytes.MappedFile.acquireByteStore(MappedFile.java:175)
      	at net.openhft.chronicle.bytes.MappedBytes.acquireNextByteStore(MappedBytes.java:172)
      	... 23 more
      processed: 19910 total: 19910
      RESUME 
      KILL
      processed: 64064 total: 83974
      RESUME 
      KILL
      processed: 0 total: 83974
      RESUME 
      KILL
      processed: 0 total: 83974
      RESUME 
      KILL
      processed: 0 total: 83974
      RESUME 
      KILL
      processed: 0 total: 83974
      RESUME 
      KILL
      processed: 0 total: 83974
      RESUME 
      KILL
      processed: 0 total: 83974
      RESUME 
      KILL
      processed: 0 total: 83974
      RESUME 
      KILL
      processed: 0 total: 83974
      

        Attachments

          Issue Links

            Activity

              People

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

                Dates

                • Created:
                  Updated:
                  Resolved: