xueyiming 1 týždeň pred
rodič
commit
8d6490586a

+ 1 - 1
src/main/scala/com/aliyun/odps/spark/examples/makedata_ad/v20240718/diff_data_20250422.scala

@@ -33,7 +33,7 @@ object diff_data_20250422 {
 
     val odpsData2 = odpsOps.readTable(project = "loghubods",
       table = "loghubods.ad_engine_statistics_log_per5min_new",
-      partition = "dt BETWEEN 20250421220000 and 20250421235500",
+      partition = "(dt BETWEEN '20250421220000' and '20250421235500')",
       transfer = func1,
       numPartition = 64)