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

TestPatternQueuingKafka#killConsumers failing randomly

    XMLWordPrintable

    Details

    • Type: Bug
    • Status: Open
    • Priority: Minor
    • Resolution: Unresolved
    • Affects Version/s: None
    • Fix Version/s: 2023.x
    • Component/s: Streams

      Description

      Observed on 2023 in mongodb environment:

      [2023-10-17T07:19:09.454Z] [ERROR] Tests run: 4, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 1.567 s <<< FAILURE! - in org.nuxeo.lib.stream.tests.pattern.TestPatternQueuingKafka
      [2023-10-17T07:19:09.454Z] [ERROR] killConsumers(org.nuxeo.lib.stream.tests.pattern.TestPatternQueuingKafka)  Time elapsed: 0.376 s  <<< ERROR!
      [2023-10-17T07:19:09.454Z] java.lang.NullPointerException: Cannot invoke "org.apache.kafka.clients.consumer.KafkaConsumer.wakeup()" because "this.consumer" is null
      [2023-10-17T07:19:09.454Z] 	at org.nuxeo.lib.stream.log.kafka.KafkaLogTailer.close(KafkaLogTailer.java:429)
      [2023-10-17T07:19:09.454Z] 	at java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
      [2023-10-17T07:19:09.454Z] 	at java.base/java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:179)
      [2023-10-17T07:19:09.454Z] 	at java.base/java.util.concurrent.ConcurrentHashMap$KeySpliterator.forEachRemaining(ConcurrentHashMap.java:3573)
      [2023-10-17T07:19:09.454Z] 	at java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:509)
      [2023-10-17T07:19:09.454Z] 	at java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499)
      [2023-10-17T07:19:09.454Z] 	at java.base/java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
      [2023-10-17T07:19:09.454Z] 	at java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
      [2023-10-17T07:19:09.454Z] 	at java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
      [2023-10-17T07:19:09.454Z] 	at java.base/java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:596)
      [2023-10-17T07:19:09.454Z] 	at org.nuxeo.lib.stream.log.internals.AbstractLogManager.close(AbstractLogManager.java:226)
      [2023-10-17T07:19:09.454Z] 	at org.nuxeo.lib.stream.log.kafka.KafkaLogManager.close(KafkaLogManager.java:148)
      [2023-10-17T07:19:09.455Z] 	at org.nuxeo.lib.stream.tests.pattern.TestPatternQueuing.closeManager(TestPatternQueuing.java:68)
      [2023-10-17T07:19:09.455Z] 	at org.nuxeo.lib.stream.tests.pattern.TestPatternQueuing.resetManager(TestPatternQueuing.java:74)
      [2023-10-17T07:19:09.455Z] 	at org.nuxeo.lib.stream.tests.pattern.TestPatternQueuing.killConsumers(TestPatternQueuing.java:168)
      

      Can be observerd on the first mongodb UT run here:
      https://jenkins.platform.dev.nuxeo.com/blue/organizations/jenkins/nuxeo%2Flts%2Fnuxeo/detail/2023/639/pipeline/297/

        Attachments

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              nalkotob Nour Al Kotob
              Participants:
            • Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

              • Created:
                Updated: