测试任务

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

@@ -41,7 +41,7 @@ object makedata_ad_32_bucket_hive_test {
     for (element <- result) {
       val map = processString(element)
       val value = sc.parallelize(map.toSeq)
-      odpsOps.saveToTable(project, table, partition, value, write)
+      odpsOps.saveToTable(project, table, partition, value, write, true)
       val row = Row(
         map.getOrElse("has_click", null).asInstanceOf[Long],
         map.getOrElse("has_conversion", null).asInstanceOf[Long],