Type mismatch when the VLAN value is taken from the ethernet header:
org.bson.BsonInvalidOperationException: Value expected to be of type INT64 is of unexpected type INT32
at org.bson.BsonValue.throwIfInvalidType(BsonValue.java:419) ~[?:?]
at org.bson.BsonValue.asInt64(BsonValue.java:105) ~[?:?]
at org.opennms.netmgt.telemetry.protocols.sflow.adapter.SFlow.lambda$getVlan$19(SFlow.java:293) ~[?:?]
at java.util.Optional.map(Optional.java:265) ~[?:?]
at org.opennms.netmgt.telemetry.protocols.sflow.adapter.SFlow.getVlan(SFlow.java:293) ~[?:?]
at org.opennms.netmgt.flows.elastic.FlowDocument.from(FlowDocument.java:636) ~[?:?]
at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195) ~[?:?]
at java.util.LinkedList$LLSpliterator.forEachRemaining(LinkedList.java:1239) ~[?:?]
at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484) ~[?:?]
at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474) ~[?:?]
at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:913) ~[?:?]
at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) ~[?:?]
at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:578) ~[?:?]
at org.opennms.netmgt.flows.elastic.ElasticFlowRepository.persist(ElasticFlowRepository.java:198) ~[?:?]
at org.opennms.netmgt.flows.elastic.InitializingFlowRepository.persist(InitializingFlowRepository.java:76) ~[?:?]
at Proxy721d0a43_fd2e_4040_bf42_efd6fff06950.persist(Unknown Source) ~[?:?]
at org.opennms.netmgt.telemetry.protocols.flows.AbstractFlowAdapter.handleMessageLog(AbstractFlowAdapter.java:105) ~[?:?]
at org.opennms.netmgt.telemetry.daemon.TelemetryMessageConsumer.handleMessage(TelemetryMessageConsumer.java:110) ~[?:?]
at org.opennms.netmgt.telemetry.daemon.TelemetryMessageConsumer.handleMessage(TelemetryMessageConsumer.java:58) ~[?:?]
at org.opennms.core.ipc.sink.common.AbstractMessageConsumerManager.lambda$dispatch$0(AbstractMessageConsumerManager.java:90) ~[?:?]
at java.lang.Iterable.forEach(Iterable.java:75) [?:?]
at org.opennms.core.ipc.sink.common.AbstractMessageConsumerManager.dispatch(AbstractMessageConsumerManager.java:90) [183:org.opennms.core.ipc.sink.common:24.0.0]
at org.opennms.core.ipc.sink.kafka.server.KafkaMessageConsumerManager$KafkaConsumerRunner.run(KafkaMessageConsumerManager.java:107) [184:org.opennms.core.ipc.sink.kafka.server:24.0.0]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) [?:?]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) [?:?]
at java.lang.Thread.run(Thread.java:834) [?:?]
Type mismatch when the VLAN value is taken from the ethernet header:
org.bson.BsonInvalidOperationException: Value expected to be of type INT64 is of unexpected type INT32 at org.bson.BsonValue.throwIfInvalidType(BsonValue.java:419) ~[?:?] at org.bson.BsonValue.asInt64(BsonValue.java:105) ~[?:?] at org.opennms.netmgt.telemetry.protocols.sflow.adapter.SFlow.lambda$getVlan$19(SFlow.java:293) ~[?:?] at java.util.Optional.map(Optional.java:265) ~[?:?] at org.opennms.netmgt.telemetry.protocols.sflow.adapter.SFlow.getVlan(SFlow.java:293) ~[?:?] at org.opennms.netmgt.flows.elastic.FlowDocument.from(FlowDocument.java:636) ~[?:?] at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195) ~[?:?] at java.util.LinkedList$LLSpliterator.forEachRemaining(LinkedList.java:1239) ~[?:?] at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484) ~[?:?] at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474) ~[?:?] at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:913) ~[?:?] at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) ~[?:?] at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:578) ~[?:?] at org.opennms.netmgt.flows.elastic.ElasticFlowRepository.persist(ElasticFlowRepository.java:198) ~[?:?] at org.opennms.netmgt.flows.elastic.InitializingFlowRepository.persist(InitializingFlowRepository.java:76) ~[?:?] at Proxy721d0a43_fd2e_4040_bf42_efd6fff06950.persist(Unknown Source) ~[?:?] at org.opennms.netmgt.telemetry.protocols.flows.AbstractFlowAdapter.handleMessageLog(AbstractFlowAdapter.java:105) ~[?:?] at org.opennms.netmgt.telemetry.daemon.TelemetryMessageConsumer.handleMessage(TelemetryMessageConsumer.java:110) ~[?:?] at org.opennms.netmgt.telemetry.daemon.TelemetryMessageConsumer.handleMessage(TelemetryMessageConsumer.java:58) ~[?:?] at org.opennms.core.ipc.sink.common.AbstractMessageConsumerManager.lambda$dispatch$0(AbstractMessageConsumerManager.java:90) ~[?:?] at java.lang.Iterable.forEach(Iterable.java:75) [?:?] at org.opennms.core.ipc.sink.common.AbstractMessageConsumerManager.dispatch(AbstractMessageConsumerManager.java:90) [183:org.opennms.core.ipc.sink.common:24.0.0] at org.opennms.core.ipc.sink.kafka.server.KafkaMessageConsumerManager$KafkaConsumerRunner.run(KafkaMessageConsumerManager.java:107) [184:org.opennms.core.ipc.sink.kafka.server:24.0.0] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) [?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) [?:?] at java.lang.Thread.run(Thread.java:834) [?:?]