소스 검색

测试任务

xueyiming 2 달 전
부모
커밋
6a10b6ad2e
1개의 변경된 파일1개의 추가작업 그리고 1개의 파일을 삭제
  1. 1 1
      src/main/scala/com/aliyun/odps/spark/examples/makedata_ad/v20240718/makedata_ad_32_bucket_hive_test.scala

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

@@ -29,7 +29,7 @@ object makedata_ad_32_bucket_hive_test {
     val param = ParamUtils.parseArgs(args)
     val project = param.getOrElse("project", "loghubods")
     val table = param.getOrElse("table", "ad_easyrec_train_data_v1")
-    val partition = "20250101"
+    val partition = "dt=20250101"
 
     val result = new ArrayBuffer[String]()