...
|
...
|
@@ -33,7 +33,7 @@ public class ExecutorBuilder { |
|
|
|
|
|
|
|
|
public ExecutorBuilder sparkConf() {
|
|
|
sparkConf = () -> new SparkConf().setAppName(APP_NAME);
|
|
|
sparkConf = () -> new SparkConf().setAppName(APP_NAME).set("spark.serializer", "org.apache.spark.serializer.KryoSerializer");
|
|
|
return this;
|
|
|
}
|
|
|
|
...
|
...
|
|