From 13fccf6ad9b0a93f1f1296bdc5d183f1fbc903a2 Mon Sep 17 00:00:00 2001 From: Alexander Bezzubov Date: Tue, 7 Apr 2015 16:35:00 +0900 Subject: [PATCH] ZEPPELIN-28 propagate empty interpreter vars to Spark conf --- .../java/org/apache/zeppelin/spark/SparkInterpreter.java | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/spark/src/main/java/org/apache/zeppelin/spark/SparkInterpreter.java b/spark/src/main/java/org/apache/zeppelin/spark/SparkInterpreter.java index 71c5ab5ef74..2461109e8c1 100644 --- a/spark/src/main/java/org/apache/zeppelin/spark/SparkInterpreter.java +++ b/spark/src/main/java/org/apache/zeppelin/spark/SparkInterpreter.java @@ -259,10 +259,8 @@ public SparkContext createSparkContext() { for (Object k : intpProperty.keySet()) { String key = (String) k; Object value = intpProperty.get(key); - if (!isEmptyString(value)) { - logger.debug(String.format("SparkConf: key = [%s], value = [%s]", key, value)); - conf.set(key, (String) value); - } + logger.debug(String.format("SparkConf: key = [%s], value = [%s]", key, value)); + conf.set(key, (String) value); } SparkContext sparkContext = new SparkContext(conf);