xueyiming il y a 1 semaine
Parent
commit
f298b26900

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

@@ -32,7 +32,7 @@ object diff_data_20250422 {
       numPartition = 64)
 
     val odpsData2 = odpsOps.readTable(project = "loghubods",
-      table = "loghubods.loghubods.ad_engine_statistics_log_per_linshi_dt",
+      table = "ad_engine_statistics_log_per_linshi_dt",
       partition = "dt=20250421",
       transfer = func1,
       numPartition = 64).map(record => {