|
@@ -12,8 +12,8 @@ object env {
|
|
|
def getODPS(sparkContext: SparkContext): OdpsOps = {
|
|
|
val accessKeyId = "LTAIWYUujJAm7CbH"
|
|
|
val accessKeySecret = "RfSjdiWwED1sGFlsjXv0DlfTnZTG1P"
|
|
|
- val odpsUrl = "http://service.odps.aliyun.com/api"
|
|
|
- val tunnelUrl = "http://dt.cn-hangzhou.maxcompute.aliyun-inc.com"
|
|
|
+ val odpsUrl = "https://service.cn-hangzhou-vpc.maxcompute.aliyun-inc.com/api"
|
|
|
+ val tunnelUrl = "https://dt.cn-hangzhou-vpc.maxcompute.aliyun-inc.com"
|
|
|
|
|
|
OdpsOps(sparkContext, accessKeyId, accessKeySecret, odpsUrl, tunnelUrl)
|
|
|
}
|