Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1595#discussion_r155254371
--- Diff:
integration/spark2/src/main/scala/org/apache/spark/sql/hive/CarbonAnalysisRules.scala
---
@@ -49,10 +49,22 @@ 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")) {
+ relation
+ } else if (sparkSession.version.startsWith("2.2")) {
+ alias match {
+ case Some(a) =>
CarbonReflectionUtils.getSubqueryAlias(sparkSession, alias, relation,
--- End diff --
move line down after =>
---
