Repository: carbondata Updated Branches: refs/heads/master df002af3d -> 4b113b865
[CARBONDATA-2266] Fixed All Examples are throwing Exception in current master branch Problem: Running all examples are showing same exception, Exception in thread main java.util.NoSuchElementException: spark.carbon.common.listener.register.classname This closes #2085 Project: http://git-wip-us.apache.org/repos/asf/carbondata/repo Commit: http://git-wip-us.apache.org/repos/asf/carbondata/commit/4b113b86 Tree: http://git-wip-us.apache.org/repos/asf/carbondata/tree/4b113b86 Diff: http://git-wip-us.apache.org/repos/asf/carbondata/diff/4b113b86 Branch: refs/heads/master Commit: 4b113b8655e1a9f980d10c36e921e9984b629f77 Parents: df002af Author: anubhav100 <[email protected]> Authored: Wed Mar 21 13:13:48 2018 +0530 Committer: chenliang613 <[email protected]> Committed: Wed Mar 21 20:43:13 2018 +0800 ---------------------------------------------------------------------- .../spark2/src/main/scala/org/apache/spark/sql/CarbonEnv.scala | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/carbondata/blob/4b113b86/integration/spark2/src/main/scala/org/apache/spark/sql/CarbonEnv.scala ---------------------------------------------------------------------- diff --git a/integration/spark2/src/main/scala/org/apache/spark/sql/CarbonEnv.scala b/integration/spark2/src/main/scala/org/apache/spark/sql/CarbonEnv.scala index 95bbd29..4a76bca 100644 --- a/integration/spark2/src/main/scala/org/apache/spark/sql/CarbonEnv.scala +++ b/integration/spark2/src/main/scala/org/apache/spark/sql/CarbonEnv.scala @@ -19,6 +19,8 @@ package org.apache.spark.sql import java.util.concurrent.ConcurrentHashMap +import scala.util.Try + import org.apache.spark.sql.catalyst.TableIdentifier import org.apache.spark.sql.catalyst.analysis.NoSuchTableException import org.apache.spark.sql.execution.command.preaaggregate._ @@ -171,8 +173,8 @@ object CarbonEnv { } def registerCommonListener(sparkSession: SparkSession): Unit = { - val clsName = sparkSession.sparkContext.conf - .get(CarbonCommonConstants.CARBON_COMMON_LISTENER_REGISTER_CLASSNAME) + val clsName = Try(sparkSession.sparkContext.conf + .get(CarbonCommonConstants.CARBON_COMMON_LISTENER_REGISTER_CLASSNAME)).toOption.getOrElse("") if (null != clsName && !clsName.isEmpty) { CarbonReflectionUtils.createObject(clsName) }
