influxdata / influxdata/influxdb-java
InfluxDBResultMapper throws ClassCastException with MessagePack Response Format
- Vorherrschende Sprache
- Java
- Sterne
- 1.2k
- Forks
- 469
- PR-Merge-Kennzahlen
- Keine gemergten PRs in 30 T.
Beschreibung
I'm using InfluxDB and telegraf to monitor machine memory, then I encounted a ClassCastException.
The query in InfluxDB returns:
```
select last(available_percent) as available_percent, total from mem
name: mem
time available_percent total
---- ----------------- -----
1569324120000 85.13442402872242 3954188288
```
According to https://github.com/influxdata/telegraf/tree/master/plugins/inputs/mem, total is an integer and available_percent is a float, so I create a class as follows:
```
@Measurement(name = "mem")
public class Mem {
@Column(name = "time")
private Instant time;
@Column(name = "total")
private long total;
@Column(name = "available_percent")
private double availablePercent;
// getter and setter ommitted
```
After connected to InfluxDB with MessagePack response format, I execute the query.
```
public class InfluxDBTest {
private static final String DATABASE = "telegraf";
private static InfluxDB establishConnection() {
InfluxDB influxDB = new InfluxDBImpl("http://172.16.172.100:8086", null, null, new OkHttpClient.Builder(),
InfluxDB.ResponseFormat.MSGPACK);
influxDB.setDatabase(DATABASE);
influxDB.setLogLevel(InfluxDB.LogLevel.FULL);
influxDB.disableBatch();
return influxDB;
}
public static void main(String[] args) {
InfluxDB influxDB = establishConnection();
QueryResult queryResult = influxDB.query(
new Query("select last(available_percent) as available_percent, total from mem"));
InfluxDBResultMapper resultMapper = new InfluxDBResultMapper();
List mems = resultMapper.toPOJO(queryResult, Mem.class, TimeUnit.MILLISECONDS);
System.out.println(mems);
}
}
```
Then an exception was thrown as follows:
```
Exception in thread "main" org.influxdb.InfluxDBMapperException: Class 'com.suntao.model.Mem' field 'total' was defined with a different field type and caused a ClassCastException. The correct type is 'java.lang.Long' (current field value: '3954188288').
at org.influxdb.impl.InfluxDBResultMapper.setFieldValue(InfluxDBResultMapper.java:327)
at org.influxdb.impl.InfluxDBResultMapper.parseSeriesAs(InfluxDBResultMapper.java:266)
at org.influxdb.impl.InfluxDBResultMapper.lambda$null$2(InfluxDBResultMapper.java:179)
```
I tried to debug, then I found it seemed that the value deserialized from MessagePack is of type Long, and the field in class is also of type long, but fieldValueForPrimitivesModified or fieldValueForPrimitiveWrappersModified method all want to cast the returned value as Double, which caused the exception.
Project settings are as follows:
- influxdb-java 2.15
- InfluxDB 1.7.8
- Java 1.8.192
Beitragsleitfaden
Für dieses Repository ist kein Beitragsleitfaden indexiert
Bewertung
Dieses Issue wurde noch nicht bewertet.