Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1595#discussion_r155438305
--- Diff:
integration/spark2/src/main/scala/org/apache/spark/sql/hive/CarbonAnalysisRules.scala
---
@@ -152,7 +165,19 @@ case class CarbonIUDAnalysisRule(sparkSession:
SparkSession) extends Rule[Logica
val projList =
Seq(UnresolvedAlias(UnresolvedStar(alias.map(Seq(_)))), tupleId)
// include tuple id in subquery
- Project(projList, relation)
+ if (sparkSession.version.startsWith("2.1")) {
+ Project(projList, relation)
+ } else if (sparkSession.version.startsWith("2.2")) {
+ alias match {
+ case Some(a) =>
+ val subqueryAlias =
CarbonReflectionUtils.getSubqueryAlias(sparkSession, alias
--- End diff --
Format properly
```
CarbonReflectionUtils.getSubqueryAlias(
sparkSession,
alias,
relation,
Some(table.tableIdentifier))
```
---
