From eede534c768cafcf82772072422a8d46e1835c9f Mon Sep 17 00:00:00 2001
From: "lizhongkang@qniao.cn" <qn123456>
Date: Thu, 7 Jul 2022 14:22:32 +0800
Subject: [PATCH] =?UTF-8?q?feat=EF=BC=9A=E6=9B=B4=E6=94=B9oss=E6=A1=B6?=
 =?UTF-8?q?=E5=90=8D=E7=A7=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/com/qniao/iot/rc/RootCloudIotDataFormatterJob.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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<MachineIotDataReceivedEvent> sink = StreamingFileSink.forRowFormat(
                 new Path(outputPath),
                 new SimpleStringEncoder<MachineIotDataReceivedEvent>("UTF-8")