Details
-
Bug
-
Status: Resolved (View Workflow)
-
Major
-
Resolution: Fixed
-
26.0.0
-
None
-
Security Level: Default (Default Security Scheme)
-
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.