Github user jackylk commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1595#discussion_r155458976
--- Diff:
integration/spark2/src/main/scala/org/apache/spark/sql/hive/CarbonAnalysisRules.scala
---
@@ -49,10 +49,26 @@ case class CarbonIUDAnalysisRule(sparkSession:
SparkSession) extends Rule[Logica
val projList =
Seq(UnresolvedAlias(UnresolvedStar(alias.map(Seq(_)))), tupleId)
+ val tableRelation = if (sparkSession.version.startsWith("2.1")) {
--- End diff --
use org.apache.spark.SPARK_VERSION instead of using sparkSession object
---