瀏覽代碼

MOD:clickhouse--sql格式修改

cxyu 3 年之前
父節點
當前提交
901ccf0668

+ 1 - 1
flink-ad-monitoring/src/main/java/flink/zanxiangnet/ad/monitoring/clickhouse/sink/BatchSinkHour.java

@@ -39,7 +39,7 @@ public class BatchSinkHour extends RichSinkFunction<CostHourDM> {
         String sql = "insert into data_monitoring.cost_hour " +
         String sql = "insert into data_monitoring.cost_hour " +
                 "(dt,\n" +
                 "(dt,\n" +
                 "create_time,\n" +
                 "create_time,\n" +
-                "hour,\n" +
+                "`hour`,\n" +
                 "ad_id,\n" +
                 "ad_id,\n" +
                 "adgroup_id,\n" +
                 "adgroup_id,\n" +
                 "adcreative_id,\n" +
                 "adcreative_id,\n" +

+ 1 - 1
flink-ad-monitoring/src/main/java/flink/zanxiangnet/ad/monitoring/clickhouse/sink/BatchSinkMinute.java

@@ -41,7 +41,7 @@ public class BatchSinkMinute extends RichSinkFunction<CostMinuterDM> {
                 "(dt,\n" +
                 "(dt,\n" +
                 "minute,\n" +
                 "minute,\n" +
                 "create_time,\n" +
                 "create_time,\n" +
-                "hour,\n" +
+                "`hour`,\n" +
                 "ad_id,\n" +
                 "ad_id,\n" +
                 "adgroup_id,\n" +
                 "adgroup_id,\n" +
                 "adcreative_id,\n" +
                 "adcreative_id,\n" +