Uploaded image for project: 'OpenNMS'
  1. OpenNMS
  2. NMS-12660

NPE in KafkaFlowForwarder

    XMLWordPrintable

    Details

    • Type: Bug
    • Status: Resolved (View Workflow)
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 26.0.0
    • Fix Version/s: 26.1.0
    • Component/s: None
    • Security Level: Default (Default Security Scheme)
    • Labels:
      None

      Description

      Exception:

      2020-04-12T04:33:08,077 | ERROR | Camel (sinkServer) thread #109 - JmsConsumer[OpenNMS.Sink.Telemetry-Netflow-5] | KafkaFlowForwarder               | 266 - org.opennms.features.flows.kafka-persistence - 26.1.0.SNAPSHOT | Exception while sending flow to kafka.
      java.lang.NullPointerException: null
              at org.opennms.netmgt.flows.persistence.model.NodeInfo$Builder.setForeginId(NodeInfo.java:729) ~[?:?]
              at org.opennms.netmgt.flows.persistence.FlowDocumentBuilder.buildNodeInfo(FlowDocumentBuilder.java:210) ~[?:?]
              at org.opennms.netmgt.flows.persistence.FlowDocumentBuilder.buildFlowDocument(FlowDocumentBuilder.java:105) ~[?:?]
              at org.opennms.netmgt.flows.persistence.KafkaFlowForwarder.forward(KafkaFlowForwarder.java:79) ~[?:?]
              at Proxy3aef1421_35be_41d5_af54_a60cc19ef11b.forward(Unknown Source) ~[?:?]
              at java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183) ~[?:?]
              at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195) ~[?:?]
              at java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1654) ~[?:?]
              at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484) ~[?:?]
              at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474) ~[?:?]
              at java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150) ~[?:?]
              at java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173) ~[?:?]
              at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) ~[?:?]
              at java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:497) ~[?:?]
              at org.opennms.netmgt.flows.elastic.ElasticFlowRepository.persist(ElasticFlowRepository.java:249) ~[?:?] 

      We should add unit test coverage to the FlowDocumentBuilder.

        Attachments

          Activity

            People

            Assignee:
            cgorantla Chandra Gorantla
            Reporter:
            j-white Jesse White
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

              Dates

              Created:
              Updated:
              Resolved: