From 356569fc12b68d04c8e163e762b3ea21b4e2d2a5 Mon Sep 17 00:00:00 2001
From: "1049970895@qniao.cn" <1049970895>
Date: Tue, 6 Sep 2022 16:10:15 +0800
Subject: [PATCH] =?UTF-8?q?=E6=9B=B4=E6=96=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/qniao/iot/gizwits/GizWitsIotDataFormatterJob.java     | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/iot-gizwits-statistics/src/main/java/com/qniao/iot/gizwits/GizWitsIotDataFormatterJob.java b/iot-gizwits-statistics/src/main/java/com/qniao/iot/gizwits/GizWitsIotDataFormatterJob.java
index 6cd973c..ed2d54a 100644
--- a/iot-gizwits-statistics/src/main/java/com/qniao/iot/gizwits/GizWitsIotDataFormatterJob.java
+++ b/iot-gizwits-statistics/src/main/java/com/qniao/iot/gizwits/GizWitsIotDataFormatterJob.java
@@ -126,7 +126,7 @@ public class GizWitsIotDataFormatterJob {
         ).name("machineIotDataReceivedEvent kafka Sink");
 
         // 发送到OSS存储
-        /*String outputPath = ApolloConfig.get(ConfigConstant.SINK_OSS_PATH);
+        String outputPath = ApolloConfig.get(ConfigConstant.SINK_OSS_PATH);
 
         StreamingFileSink<String> sink = StreamingFileSink.forRowFormat(
                 new Path(outputPath),
@@ -173,7 +173,7 @@ public class GizWitsIotDataFormatterJob {
             public String map(MachineIotDataReceivedEvent value) {
                 return JSONUtil.toJsonStr(value);
             }
-        }).addSink(sink);*/
+        }).addSink(sink);
 
         env.execute("gizwits iot data formatter job");
     }