You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@spark.apache.org by "Apache Spark (JIRA)" <ji...@apache.org> on 2017/05/20 08:09:04 UTC
[jira] [Commented] (SPARK-20816) MetricsConfig doen't trim the
properties file cause the exception very confused
[ https://issues.apache.org/jira/browse/SPARK-20816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16018361#comment-16018361 ]
Apache Spark commented on SPARK-20816:
--------------------------------------
User 'LantaoJin' has created a pull request for this issue:
https://github.com/apache/spark/pull/18041
> MetricsConfig doen't trim the properties file cause the exception very confused
> --------------------------------------------------------------------------------
>
> Key: SPARK-20816
> URL: https://issues.apache.org/jira/browse/SPARK-20816
> Project: Spark
> Issue Type: Improvement
> Components: Spark Core
> Affects Versions: 2.1.1
> Reporter: Lantao Jin
> Priority: Minor
>
> Spark Metrics System use a {{Properties File}} to load the configurations but doesn't trim the keys and values. It might cause the exception very confused if the property is a class name.
> For example below, you must do not notice there is a space at the line end.
> {quote}
> *.sink.ganglia.class=org.apache.spark.metrics.sink.GangliaSink
> {quote}
> Unfortunately, the {{ClassNotFoundException}} throwing from Driver also doesn't tell me what happens and confuses me because I am sure the related jar is in the CLASSPATH.
> {quote}
> 17/05/20 12:47:04 ERROR SparkContext: Error initializing SparkContext.
> java.lang.ClassNotFoundException: org.apache.spark.metrics.sink.GangliaSink
> at scala.reflect.internal.util.AbstractFileClassLoader.findClass(AbstractFileClassLoader.scala:62)
> {quote}
> As a reference, I check the code of Log4j, a classic {{Properties}} using library. It do the trim when load the properties.
> {code:title=org.apache.log4j.filter.PropertyFilter.java|borderStyle=solid}
> private Hashtable parseProperties(String props) {
> Hashtable hashTable = new Hashtable();
> StringTokenizer pairs = new StringTokenizer(props, ",");
> while (pairs.hasMoreTokens()) {
> StringTokenizer entry = new StringTokenizer(pairs.nextToken(), "=");
> hashTable.put(entry.nextElement().toString().trim(), entry.nextElement().toString().trim());
> }
> return hashTable;
> }
> {code}
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscribe@spark.apache.org
For additional commands, e-mail: issues-help@spark.apache.org