修改字段

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{

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);
     }