search

giros-dit / semantic-data-aggregator

A semantic monitoring framework for aggregating data from heterogeneous sources.
Apache License 2.0
4 stars 0 forks source link

Upload to SDA new image of drivers after actualizing yang model #76

Closed ghost closed 2 years ago

ghost commented 2 years ago

When trying to deplay netflow-driver in application node with kubernetes the following error is appearing:

Failure Reasons:
        java.lang.NumberFormatException: String value 1649459286684 exceeds range of unsigned int.
  at java.base/java.lang.Integer.parseUnsignedInt(Unknown Source)
  at org.opendaylight.yangtools.yang.common.Uint32.valueOf(Uint32.java:245)
  at org.opendaylight.yangtools.yang.common.Uint32.valueOf(Uint32.java:229)
  at org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev130715.Timestamp.getDefaultInstance(Timestamp.java:54)
  at tid.NetflowDriver.driver(NetflowDriver.java:256)
  at tid.NetflowDriver$2.map(NetflowDriver.java:138)
  at tid.NetflowDriver$2.map(NetflowDriver.java:133)
  at org.apache.flink.streaming.api.operators.StreamMap.processElement(StreamMap.java:38)
  at org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.pushToOperator(CopyingChainingOutput.java:82)
  at org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.collect(CopyingChainingOutput.java:57)
  at org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.collect(CopyingChainingOutput.java:29)
  at org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:56)
  at org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:29)
  at org.apache.flink.streaming.api.operators.StreamSourceContexts$ManualWatermarkContext.processAndCollectWithTimestamp(StreamSourceContexts.java:423)
  at org.apache.flink.streaming.api.operators.StreamSourceContexts$WatermarkContext.collectWithTimestamp(StreamSourceContexts.java:528)
  at org.apache.flink.streaming.api.operators.StreamSourceContexts$SwitchingOnClose.collectWithTimestamp(StreamSourceContexts.java:108)
  at org.apache.flink.streaming.connectors.kafka.internals.AbstractFetcher.emitRecordsWithTimestamps(AbstractFetcher.java:365)
  at org.apache.flink.streaming.connectors.kafka.internals.KafkaFetcher.partitionConsumerRecordsHandler(KafkaFetcher.java:183)
  at org.apache.flink.streaming.connectors.kafka.internals.KafkaFetcher.runFetchLoop(KafkaFetcher.java:142)
  at org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase.run(FlinkKafkaConsumerBase.java:826)
  at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:110)
  at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:67)
  at org.apache.flink.streaming.runtime.tasks.SourceStreamTask$LegacySourceFunctionThread.run(SourceStreamTask.java:323)

It could be something related with the change of yang models and updating the goflow but not .jar of the driver loaded in kubernetes