|
@@ -1431,7 +1431,7 @@ object makedata_ad_32_bucket_hive_test {
|
|
|
// 创建 DataFrame
|
|
|
val df = spark.createDataFrame(spark.sparkContext.parallelize(rows), schema)
|
|
|
|
|
|
- df.write.format("com.aliyun.odps.spark.sql")
|
|
|
+ df.write
|
|
|
.option("odpsUrl", "http://service.odps.aliyun.com/api")
|
|
|
.option("tunnelUrl", "http://dt.cn-hangzhou.maxcompute.aliyun-inc.com")
|
|
|
.option("table", table)
|