Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1975#discussion_r170171750
--- Diff:
integration/spark2/src/main/scala/org/apache/spark/sql/execution/command/preaaggregate/PreAggregateUtil.scala
---
@@ -445,11 +443,11 @@ object PreAggregateUtil {
.fromWrapperToExternalTableInfo(wrapperTableInfo, dbName,
tableName)
updateSchemaInfo(carbonTable,
thriftTable)(sparkSession)
- LOGGER.info(s"Parent table updated is successful for table
$dbName.$tableName")
+ LOGGER.info(s"Parent table updated is successful for table" +
+ s"
$dbName.${childSchema.getRelationIdentifier.toString}")
} catch {
case e: Exception =>
LOGGER.error(e, "Pre Aggregate Parent table update failed
reverting changes")
- revertMainTableChanges(dbName, tableName,
numberOfCurrentChild)(sparkSession)
--- End diff --
Now where you are reverting the schema if updation fails?
---
