SparkConf sparkConf = new SparkConf(); for (Map.Entry<String, String> e : conf) { if (e.getKey().startsWith("spark.")) { sparkConf.set(e.getKey(), e.getValue()); } } this.sparkContext = new JavaSparkContext(sparkConnect, getName(), sparkConf);