feat：更改oss桶名称

3 years ago · eede534c76
1 changed files with 1 additions and 1 deletions
--- a/root-cloud-statistics/src/main/java/com/qniao/iot/rc/RootCloudIotDataFormatterJob.java
+++ b/root-cloud-statistics/src/main/java/com/qniao/iot/rc/RootCloudIotDataFormatterJob.java
@ -72,7 +72,7 @@ public class RootCloudIotDataFormatterJob {
                .name("Transform MachineIotDataReceivedEvent");

        // 发送到OSS存储
-        String outputPath = "oss://qn-flink-test/test";
+        String outputPath = "oss://qn-flink-test/root-cloud-model-hw-reported-data";
        StreamingFileSink<MachineIotDataReceivedEvent> sink = StreamingFileSink.forRowFormat(
                new Path(outputPath),
                new SimpleStringEncoder<MachineIotDataReceivedEvent>("UTF-8")