[influxdb] Fix query for InfluxDB2 (openhab#14542)

Signed-off-by: Jan N. Klug <github@klug.nrw>
FordPrfkt · Apr 19, 2023 · 7034561 · 7034561
1 parent 680ba57
commit 7034561
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/.../main/java/org/openhab/persistence/influxdb/internal/influx2/InfluxDB2RepositoryImpl.java b/.../main/java/org/openhab/persistence/influxdb/internal/influx2/InfluxDB2RepositoryImpl.java
@@ -165,6 +165,9 @@ public List<InfluxRow> query(String query) {
     private Stream<InfluxRow> mapRawResultToHistoric(FluxTable rawRow) {
         return rawRow.getRecords().stream().map(r -> {
             String itemName = (String) r.getValueByKey(InfluxDBConstants.TAG_ITEM_NAME);
+            if (itemName == null) {
+                itemName = r.getMeasurement();
+            }
             Object value = r.getValueByKey(COLUMN_VALUE_NAME_V2);
             Instant time = (Instant) r.getValueByKey(COLUMN_TIME_NAME_V2);
             return new InfluxRow(time, itemName, value);