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