更新

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