diff --git a/root-cloud-event/src/main/java/com/qniao/iot/rc/RootCloudIotDataReceiptedEvent.java b/root-cloud-event/src/main/java/com/qniao/iot/rc/RootCloudIotDataReceiptedEvent.java
index 05ed043..400f26e 100644
--- a/root-cloud-event/src/main/java/com/qniao/iot/rc/RootCloudIotDataReceiptedEvent.java
+++ b/root-cloud-event/src/main/java/com/qniao/iot/rc/RootCloudIotDataReceiptedEvent.java
@@ -165,7 +165,8 @@ public class RootCloudIotDataReceiptedEvent implements Serializable {
 
     private Online __online__;
 
-    private String __thingName__;
+    @JsonProperty(value = "__thingName__")
+    private String thingName;
 
     @Data
     public static class Online{
diff --git a/root-cloud-statistics/src/main/java/com/qniao/iot/rc/event/RootCloudIotDataReceiptedEventDeserializationSchema.java b/root-cloud-statistics/src/main/java/com/qniao/iot/rc/event/RootCloudIotDataReceiptedEventDeserializationSchema.java
index 6dd0725..58484b4 100644
--- a/root-cloud-statistics/src/main/java/com/qniao/iot/rc/event/RootCloudIotDataReceiptedEventDeserializationSchema.java
+++ b/root-cloud-statistics/src/main/java/com/qniao/iot/rc/event/RootCloudIotDataReceiptedEventDeserializationSchema.java
@@ -1,5 +1,7 @@
 package com.qniao.iot.rc.event;
 
+import cn.hutool.core.util.ByteUtil;
+import cn.hutool.json.JSONUtil;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.qniao.iot.rc.RootCloudIotDataReceiptedEvent;
 import org.apache.flink.api.common.serialization.DeserializationSchema;
@@ -18,6 +20,7 @@ public class RootCloudIotDataReceiptedEventDeserializationSchema implements Dese
 
     @Override
     public RootCloudIotDataReceiptedEvent deserialize(byte[] message) throws IOException {
+
         return objectMapper.readValue(message, RootCloudIotDataReceiptedEvent.class);
     }