You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@carbondata.apache.org by ch...@apache.org on 2018/03/21 12:43:50 UTC
carbondata git commit: [CARBONDATA-2266] Fixed All Examples are
throwing Exception in current master branch
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 <an...@knoldus.in>
Authored: Wed Mar 21 13:13:48 2018 +0530
Committer: chenliang613 <ch...@huawei.com>
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)
}