Skip to content

Commit

Permalink
[ZEPPELIN-46] Some spark env must have a valid value
Browse files Browse the repository at this point in the history
- Fixed styles
  • Loading branch information
jongyoul committed Apr 17, 2015
1 parent aec31d3 commit f259a5a
Showing 1 changed file with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -149,11 +149,11 @@ public void emptyConfigurationVariablesOnlyForNonSparkProperties() {
SparkConf sparkConf = repl.getSparkContext().getConf();
for (Object oKey : intpProperty.keySet()) {
String key = (String) oKey;
String value = (String)intpProperty.get(key);
String value = (String) intpProperty.get(key);
repl.logger.debug(String.format("[%s]: [%s]", key, value));
if (key.startsWith("spark.") && value.isEmpty()) {
assertTrue(String.format("configuration starting from 'spark.' should not be empty. [%s]", key), !sparkConf.contains(key) || !sparkConf.get(key).isEmpty());
}
assertTrue(String.format("configuration starting from 'spark.' should not be empty. [%s]", key), !sparkConf.contains(key) || !sparkConf.get(key).isEmpty());
}
}
}
}

0 comments on commit f259a5a

Please sign in to comment.