From ee704e71febb3152e7534dafbe0e40214f0ceb0b Mon Sep 17 00:00:00 2001
From: Derran <zhangpengjie@qniao.cn>
Date: Sat, 17 Dec 2022 10:18:14 +0800
Subject: [PATCH] =?UTF-8?q?=E5=9B=BE=E7=89=87=E5=8F=AF=E8=83=BD=E6=B2=A1?=
 =?UTF-8?q?=E7=94=9F=E6=88=90=20todo=20=E9=9C=80=E8=A6=81=E9=97=AE?=
 =?UTF-8?q?=E4=B8=8B=E6=A0=91=E6=A0=B9=EF=BC=8C=E5=85=88=E4=BC=91=E7=9C=A0?=
 =?UTF-8?q?=E4=B8=80=E4=B8=8B?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../rootcloudstatistics/RootCloudIotDataFormatterJob.java  | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git a/ai-root-cloud-statistics/src/main/java/com/qniao/rootcloudstatistics/RootCloudIotDataFormatterJob.java b/ai-root-cloud-statistics/src/main/java/com/qniao/rootcloudstatistics/RootCloudIotDataFormatterJob.java
index 915ea1e..d8dbd1d 100644
--- a/ai-root-cloud-statistics/src/main/java/com/qniao/rootcloudstatistics/RootCloudIotDataFormatterJob.java
+++ b/ai-root-cloud-statistics/src/main/java/com/qniao/rootcloudstatistics/RootCloudIotDataFormatterJob.java
@@ -85,7 +85,6 @@ public class RootCloudIotDataFormatterJob {
 
     public static void main(String[] args) throws Exception {
 
-
         final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
         env.enableCheckpointing(60000L, CheckpointingMode.EXACTLY_ONCE);
         KafkaSource<JSONObject> source = KafkaSource.<JSONObject>builder()
@@ -154,6 +153,12 @@ public class RootCloudIotDataFormatterJob {
 
 
     private static AIWarningDataReceivedEvent transform(JSONObject event) {
+        //图片可能没生成 todo 需要问下树根，先休眠一下
+        try {
+            Thread.sleep(10000);
+        } catch (InterruptedException e) {
+            e.printStackTrace();
+        }
         AIWarningDataReceivedEvent aiWaringDataReceivedEvent = new AIWarningDataReceivedEvent();
         Object object = event.get("payload");
         if (Objects.nonNull(object)) {