diff --git a/spark/core/main/scala/org/elasticsearch/spark/cfg/SparkSettings.java b/spark/core/main/scala/org/elasticsearch/spark/cfg/SparkSettings.java
index <HASH>..<HASH> 100644
--- a/spark/core/main/scala/org/elasticsearch/spark/cfg/SparkSettings.java
+++ b/spark/core/main/scala/org/elasticsearch/spark/cfg/SparkSettings.java
@@ -52,6 +52,9 @@ public class SparkSettings extends Settings {
     @Override
     public String getProperty(String name) {
         Option<String> op = cfg.getOption(name);
+        if (!op.isDefined()) {
+            op = cfg.getOption("spark." + name);
+        }
         return (op.isDefined() ? op.get() : null);
     }
[SPARK] read "spark.es" (set through the command-line)

relates #<I>