Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1595#discussion_r155438257
--- Diff:
integration/spark2/src/main/scala/org/apache/spark/sql/hive/CarbonAnalysisRules.scala
---
@@ -49,10 +49,23 @@ 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
+ , Some(table.tableIdentifier))
--- End diff --
Format properly
```
CarbonReflectionUtils.getSubqueryAlias(
sparkSession,
alias,
relation,
Some(table.tableIdentifier))
```
---
