diff --git a/oap-server/server-storage-plugin/storage-influxdb-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/influxdb/query/AlarmQuery.java b/oap-server/server-storage-plugin/storage-influxdb-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/influxdb/query/AlarmQuery.java
index e53f8e1f3..c698accc6 100644
--- a/oap-server/server-storage-plugin/storage-influxdb-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/influxdb/query/AlarmQuery.java
+++ b/oap-server/server-storage-plugin/storage-influxdb-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/influxdb/query/AlarmQuery.java
@@ -99,7 +99,7 @@ public class AlarmQuery implements IAlarmQueryDAO {
               .sorted((a, b) -> Long.compare((long) b.get(1), (long) a.get(1)))
               .skip(from)
               .forEach(values -> {
-                  final int sid = (int) values.get(4);
+                  final int sid = ((Number) values.get(4)).intValue();
                   Scope scope = Scope.Finder.valueOf(sid);
 
                   AlarmMessage message = new AlarmMessage();
diff --git a/oap-server/server-storage-plugin/storage-influxdb-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/influxdb/query/LogQuery.java b/oap-server/server-storage-plugin/storage-influxdb-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/influxdb/query/LogQuery.java
index e47b7c331..e49115cab 100644
--- a/oap-server/server-storage-plugin/storage-influxdb-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/influxdb/query/LogQuery.java
+++ b/oap-server/server-storage-plugin/storage-influxdb-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/influxdb/query/LogQuery.java
@@ -141,7 +141,7 @@ public class LogQuery implements ILogQueryDAO {
                     data.put(columns.get(i), value);
                 }
                 log.setContent((String) data.get(CONTENT));
-                log.setContentType(ContentType.instanceOf((int) data.get(CONTENT_TYPE)));
+                log.setContentType(ContentType.instanceOf(((Number) data.get(CONTENT_TYPE)).intValue()));
 
                 log.setEndpointId((String) data.get(ENDPOINT_ID));
                 log.setEndpointName((String) data.get(ENDPOINT_NAME));
diff --git a/oap-server/server-storage-plugin/storage-influxdb-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/influxdb/query/ProfileTaskQuery.java b/oap-server/server-storage-plugin/storage-influxdb-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/influxdb/query/ProfileTaskQuery.java
index 701d70563..2ec06a5a1 100644
--- a/oap-server/server-storage-plugin/storage-influxdb-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/influxdb/query/ProfileTaskQuery.java
+++ b/oap-server/server-storage-plugin/storage-influxdb-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/influxdb/query/ProfileTaskQuery.java
@@ -134,10 +134,10 @@ public class ProfileTaskQuery implements IProfileTaskQueryDAO {
                           .endpointName((String) values.get(3))
                           .startTime(((Number) values.get(4)).longValue())
                           .createTime(((Number) values.get(5)).longValue())
-                          .duration((int) values.get(6))
-                          .minDurationThreshold((int) values.get(7))
-                          .dumpPeriod((int) values.get(8))
-                          .maxSamplingCount((int) values.get(9))
+                          .duration(((Number) values.get(6)).intValue())
+                          .minDurationThreshold(((Number) values.get(7)).intValue())
+                          .dumpPeriod(((Number) values.get(8)).intValue())
+                          .maxSamplingCount(((Number) values.get(9)).intValue())
                           .build();
     }
 
diff --git a/oap-server/server-storage-plugin/storage-influxdb-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/influxdb/query/ProfileThreadSnapshotQuery.java b/oap-server/server-storage-plugin/storage-influxdb-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/influxdb/query/ProfileThreadSnapshotQuery.java
index 2e3f2edc8..a1a7b5224 100644
--- a/oap-server/server-storage-plugin/storage-influxdb-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/influxdb/query/ProfileThreadSnapshotQuery.java
+++ b/oap-server/server-storage-plugin/storage-influxdb-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/influxdb/query/ProfileThreadSnapshotQuery.java
@@ -98,8 +98,8 @@ public class ProfileThreadSnapshotQuery implements IProfileThreadSnapshotQueryDA
                   basicTrace.setSegmentId((String) values.get(2));
                   basicTrace.setStart(String.valueOf(values.get(3)));
                   basicTrace.getEndpointNames().add((String) values.get(4));
-                  basicTrace.setDuration((int) values.get(5));
-                  basicTrace.setError(BooleanUtils.valueToBoolean((int) values.get(6)));
+                  basicTrace.setDuration(((Number) values.get(5)).intValue());
+                  basicTrace.setError(BooleanUtils.valueToBoolean(((Number) values.get(6)).intValue()));
                   String traceIds = (String) values.get(7);
                   basicTrace.getTraceIds().add(traceIds);
 
@@ -148,7 +148,7 @@ public class ProfileThreadSnapshotQuery implements IProfileThreadSnapshotQueryDA
             record.setTaskId((String) values.get(1));
             record.setSegmentId((String) values.get(2));
             record.setDumpTime(((Number) values.get(3)).longValue());
-            record.setSequence((int) values.get(4));
+            record.setSequence(((Number) values.get(4)).intValue());
             String dataBinaryBase64 = String.valueOf(values.get(5));
             if (StringUtil.isNotEmpty(dataBinaryBase64)) {
                 record.setStackBinary(Base64.getDecoder().decode(dataBinaryBase64));
diff --git a/oap-server/server-storage-plugin/storage-influxdb-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/influxdb/query/TopNRecordsQuery.java b/oap-server/server-storage-plugin/storage-influxdb-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/influxdb/query/TopNRecordsQuery.java
index 0bc00f577..9f9e56f0a 100644
--- a/oap-server/server-storage-plugin/storage-influxdb-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/influxdb/query/TopNRecordsQuery.java
+++ b/oap-server/server-storage-plugin/storage-influxdb-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/influxdb/query/TopNRecordsQuery.java
@@ -87,7 +87,7 @@ public class TopNRecordsQuery implements ITopNRecordsQueryDAO {
         final List<SelectedRecord> records = new ArrayList<>();
         series.getValues().forEach(values -> {
             SelectedRecord record = new SelectedRecord();
-            record.setValue(String.valueOf((long) values.get(1)));
+            record.setValue(String.valueOf(values.get(1)));
             record.setRefId((String) values.get(3));
             record.setName((String) values.get(2));
             records.add(record);
diff --git a/oap-server/server-storage-plugin/storage-influxdb-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/influxdb/query/TopologyQuery.java b/oap-server/server-storage-plugin/storage-influxdb-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/influxdb/query/TopologyQuery.java
index d659de3dc..a22ed4728 100644
--- a/oap-server/server-storage-plugin/storage-influxdb-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/influxdb/query/TopologyQuery.java
+++ b/oap-server/server-storage-plugin/storage-influxdb-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/influxdb/query/TopologyQuery.java
@@ -255,7 +255,7 @@ public class TopologyQuery implements ITopologyQueryDAO {
         series.getValues().forEach(values -> {
             Call.CallDetail call = new Call.CallDetail();
             String entityId = String.valueOf(values.get(1));
-            int componentId = (int) values.get(2);
+            int componentId = ((Number) values.get(2)).intValue();
             call.buildFromServiceRelation(entityId, componentId, detectPoint);
             calls.add(call);
         });
@@ -285,7 +285,7 @@ public class TopologyQuery implements ITopologyQueryDAO {
         series.getValues().forEach(values -> {
             Call.CallDetail call = new Call.CallDetail();
             String entityId = (String) values.get(1);
-            int componentId = (int) values.get(2);
+            int componentId = ((Number) values.get(2)).intValue();
             call.buildFromInstanceRelation(entityId, componentId, detectPoint);
             calls.add(call);
         });
diff --git a/oap-server/server-storage-plugin/storage-influxdb-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/influxdb/query/TraceQuery.java b/oap-server/server-storage-plugin/storage-influxdb-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/influxdb/query/TraceQuery.java
index 2b8b7c7b5..f31508294 100644
--- a/oap-server/server-storage-plugin/storage-influxdb-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/influxdb/query/TraceQuery.java
+++ b/oap-server/server-storage-plugin/storage-influxdb-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/influxdb/query/TraceQuery.java
@@ -154,10 +154,10 @@ public class TraceQuery implements ITraceQueryDAO {
             BasicTrace basicTrace = new BasicTrace();
 
             basicTrace.setSegmentId((String) values.get(2));
-            basicTrace.setStart(String.valueOf((long) values.get(3)));
+            basicTrace.setStart(String.valueOf(values.get(3)));
             basicTrace.getEndpointNames().add((String) values.get(4));
-            basicTrace.setDuration((int) values.get(5));
-            basicTrace.setError(BooleanUtils.valueToBoolean((int) values.get(6)));
+            basicTrace.setDuration(((Number) values.get(5)).intValue());
+            basicTrace.setError(BooleanUtils.valueToBoolean(((Number) values.get(6)).intValue()));
             basicTrace.getTraceIds().add((String) values.get(7));
 
             traceBrief.getTraces().add(basicTrace);
@@ -197,11 +197,11 @@ public class TraceQuery implements ITraceQueryDAO {
             segmentRecord.setServiceId((String) values.get(3));
             segmentRecord.setServiceInstanceId((String) values.get(4));
             segmentRecord.setEndpointName((String) values.get(5));
-            segmentRecord.setStartTime((long) values.get(6));
-            segmentRecord.setEndTime((long) values.get(7));
-            segmentRecord.setLatency((int) values.get(8));
-            segmentRecord.setIsError((int) values.get(9));
-            segmentRecord.setVersion((int) values.get(11));
+            segmentRecord.setStartTime(((Number) values.get(6)).longValue());
+            segmentRecord.setEndTime(((Number) values.get(7)).longValue());
+            segmentRecord.setLatency(((Number) values.get(8)).intValue());
+            segmentRecord.setIsError(((Number) values.get(9)).intValue());
+            segmentRecord.setVersion(((Number) values.get(11)).intValue());
 
             String base64 = (String) values.get(10);
             if (!Strings.isNullOrEmpty(base64)) {