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


---

Reply via email to