Possible bug prevents data to be stored after restarting opc ua server #3216
Unanswered
leonmeerfeld
asked this question in
Q&A
Replies: 0 comments
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
-
I collect about 50 values from a upc ua server. the upc ua server is connected to a wincc instance. which got restarted. After the restart ca. 20 out of the 50 stopped being inserted into the datalake. on the datalake in the pipeline I get the following error log:
java.lang.IllegalArgumentException: Expecting a positive number for fields size at org.influxdb.impl.Preconditions.checkPositiveNumber(Preconditions.java:35) at org.influxdb.dto.Point$Builder.build(Point.java:387) at org.apache.streampipes.dataexplorer.commons.influx.InfluxStore.onEvent(InfluxStore.java:79) at org.apache.streampipes.dataexplorer.commons.TimeSeriesStore.onEvent(TimeSeriesStore.java:64) at org.apache.streampipes.sinks.internal.jvm.datalake.DataLakeSink.onEvent(DataLakeSink.java:109) at org.apache.streampipes.wrapper.standalone.runtime.StandaloneEventSinkRuntime.process(StandaloneEventSinkRuntime.java:55) at org.apache.streampipes.wrapper.standalone.routing.StandaloneSpInputCollector.send(StandaloneSpInputCollector.java:56) at org.apache.streampipes.wrapper.standalone.routing.StandaloneSpInputCollector.lambda$onEvent$0(StandaloneSpInputCollector.java:51) at java.base/java.util.concurrent.ConcurrentHashMap.forEach(Unknown Source) at org.apache.streampipes.wrapper.standalone.routing.StandaloneSpInputCollector.onEvent(StandaloneSpInputCollector.java:51) at org.apache.streampipes.wrapper.standalone.routing.StandaloneSpInputCollector.onEvent(StandaloneSpInputCollector.java:30) at org.apache.streampipes.messaging.kafka.SpKafkaConsumer.lambda$run$0(SpKafkaConsumer.java:105) at java.base/java.lang.Iterable.forEach(Unknown Source) at org.apache.streampipes.messaging.kafka.SpKafkaConsumer.run(SpKafkaConsumer.java:105) at java.base/java.lang.Thread.run(Unknown Source)
Does anyone know whats going on here?
We'll test some more cases with restarts and reconnecting and I'll update here.
Beta Was this translation helpful? Give feedback.
All reactions