Issue with Enriching Flow Data

Hi

Unable to see any Flow Data in the OpenNMS Web UI - Resources Graphs:
I am trying to use OpenNMS to see the Flow data from the Switches. I followed the Troubleshoot Telemetryd knowledge article did the checks mentioned there.

I wish to see the incoming sFlow data in the OpenNMS Web UI. I can see the icon and it says "No Flows found for the current Time range. Please provide any pointers or insight on how to resolve this.

Thank you.
I did the following checks:

Telemetryd Availability

Nmap result:

Starting Nmap 7.60 ( https://nmap.org ) at 2021-03-25 14:23 PDT
Nmap scan report for localhost (127.0.0.1)
Host is up.
Other addresses for localhost (not scanned): ::1

PORT STATE SERVICE
6343/udp open|filtered sflow

Nmap done: 1 IP address (1 host up) scanned in 2.23 seconds

The flow packages are coming as well. I ran tcpdump and seeing the data coming through.

ONMS Health Check results in the following

admin@opennms> opennms:health-check
Verifying the health of the container

Verifying installed bundles [ Success ]
Connecting to ElasticSearch ReST API (Flows) [ Success ]

=> Everything is awesome

SNMP enabled and working fine. There is performance data for the Switches, but no Flow data.

OpenNMS version:

Version Details

Version: [27.1.0]
Server Time: Thu Mar 25 14:47:07 PDT 2021
Client Time: Thu Mar 25 2021 14:47:08 GMT-0700 (Pacific Daylight Time)
Java Version: 11.0.9 (Ubuntu)
Java Runtime: OpenJDK Runtime Environment (11.0.9+11-Ubuntu-0ubuntu1.18.04.1)
Java Specification: Java Platform API Specification (Oracle Corporation, 11)
Java Virtual Machine: OpenJDK 64-Bit Server VM (Ubuntu, 11.0.9+11-Ubuntu-0ubuntu1.18.04.1)
Java Virtual Machine Specification: Java Virtual Machine Specification (Oracle Corporation, 11)
Operating System: Linux 4.15.0-139-generic (amd64)
OSGi Container: Apache Karaf 4.2.6
Servlet Container: jetty/9.4.34.v20201102 (Servlet Spec 3.1)
User Agent: Mozilla/5.0 (Windows NT 10.0; Win64; x64; rv:86.0) Gecko/20100101 Firefox/86.0
Database Type: PostgreSQL
Database Version: 11.11 (Ubuntu 11.11-1.pgdg16.04+1)
Time-Series Strategy: RRDTool or JRobin
IPC Strategy: Sink: camel; RPC: jms

Other relevant data:

Logs

/var/log/opennms/telemetryd.log No errors in telemetryd.log

karaf logs shows the following

2021-03-25T14:34:38,076 | ERROR | AggregatorFlush-Telemetry-SFlow | AbstractFlowAdapter              | 326 - org.opennms.features.telemetry.protocols.flows - 27.1.0 | Error while persisting flows: Failed to enrich one or more flows.
org.opennms.netmgt.flows.api.FlowException: Failed to enrich one or more flows.
        at org.opennms.netmgt.flows.elastic.ElasticFlowRepository.persist(ElasticFlowRepository.java:232) ~[?:?]
        at org.opennms.netmgt.flows.elastic.InitializingFlowRepository.persist(InitializingFlowRepository.java:87) ~[?:?]
        at Proxy0ef62b7b_8518_4977_98b5_043e37d3f1a1.persist(Unknown Source) ~[?:?]
        at org.opennms.netmgt.telemetry.protocols.flows.AbstractFlowAdapter.handleMessageLog(AbstractFlowAdapter.java:135) ~[?:?]
        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:100) ~[?:?]
        at java.lang.Iterable.forEach(Iterable.java:75) [?:?]
        at org.opennms.core.ipc.sink.common.AbstractMessageConsumerManager.dispatch(AbstractMessageConsumerManager.java:100) [?:?]
        at org.opennms.core.ipc.sink.camel.client.CamelLocalMessageDispatcherFactory.dispatch(CamelLocalMessageDispatcherFactory.java:65) [?:?]
        at org.opennms.core.ipc.sink.camel.client.CamelLocalMessageDispatcherFactory.dispatch(CamelLocalMessageDispatcherFactory.java:53) [?:?]
        at org.opennms.core.ipc.sink.common.AbstractMessageDispatcherFactory.timedDispatch(AbstractMessageDispatcherFactory.java:86) [?:?]
        at org.opennms.core.ipc.sink.common.AbstractMessageDispatcherFactory.access$000(AbstractMessageDispatcherFactory.java:64) [?:?]
        at org.opennms.core.ipc.sink.common.AbstractMessageDispatcherFactory$1.dispatch(AbstractMessageDispatcherFactory.java:127) [?:?]
        at org.opennms.core.ipc.sink.common.AbstractMessageDispatcherFactory$1.dispatch(AbstractMessageDispatcherFactory.java:124) [?:?]
        at org.opennms.core.ipc.sink.aggregation.Aggregator.run(Aggregator.java:190) [?:?]
        at org.opennms.core.ipc.sink.aggregation.Aggregator$1.run(Aggregator.java:105) [?:?]
        at java.util.TimerThread.mainLoop(Timer.java:556) [?:?]
        at java.util.TimerThread.run(Timer.java:506) [?:?]
Caused by: org.bson.BsonInvalidOperationException: Value expected to be of type INT64 is of unexpected type DOCUMENT
        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$getInputSnmp$6(SFlow.java:195) ~[?:?]
        at java.util.Optional.map(Optional.java:265) ~[?:?]
        at org.opennms.netmgt.telemetry.protocols.sflow.adapter.SFlow.getInputSnmp(SFlow.java:195) ~[?:?]
        at org.opennms.netmgt.flows.elastic.FlowDocument.from(FlowDocument.java:739) ~[?:?]
        at org.opennms.netmgt.flows.elastic.DocumentEnricher.lambda$null$0(DocumentEnricher.java:129) ~[?:?]
        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.DocumentEnricher.lambda$enrich$1(DocumentEnricher.java:185) ~[?:?]
        at org.opennms.netmgt.dao.hibernate.DefaultSessionUtils.lambda$withTransaction$0(DefaultSessionUtils.java:68) ~[?:?]
        at org.springframework.transaction.support.TransactionTemplate.execute(TransactionTemplate.java:133) ~[?:?]
        at org.opennms.netmgt.dao.hibernate.DefaultSessionUtils.withTransaction(DefaultSessionUtils.java:68) ~[?:?]
        at Proxyfa274854_000c_4afb_b6f6_f7ed3b494052.withTransaction(Unknown Source) ~[?:?]
        at org.opennms.netmgt.flows.elastic.DocumentEnricher.enrich(DocumentEnricher.java:128) ~[?:?]
        at org.opennms.netmgt.flows.elastic.ElasticFlowRepository.persist(ElasticFlowRepository.java:230) ~[?:?]
        ... 18 more