Description
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<Mem> 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