diff --git 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 index c6d1eff..4d75a9b 100644 --- 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 sink = StreamingFileSink.forRowFormat( new Path(outputPath), new SimpleStringEncoder("UTF-8")