|
@@ -34,7 +34,7 @@ public class ODPSToRedis {
|
|
|
}
|
|
|
|
|
|
SparkConf sparkConf = new SparkConf()
|
|
|
- .setMaster("local")
|
|
|
+ //.setMaster("local")
|
|
|
.setAppName("odps sync to redis");
|
|
|
for (Map.Entry<String, String> e : argMap.entrySet()) {
|
|
|
sparkConf.set(e.getKey(), e.getValue());
|