Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1759#discussion_r159669950
--- Diff:
integration/spark2/src/main/scala/org/apache/spark/sql/execution/command/management/RefreshCarbonTableCommand.scala
---
@@ -91,6 +95,11 @@ case class RefreshCarbonTableCommand(
registerAggregates(databaseName, dataMapSchemaList)(sparkSession)
}
registerTableWithHive(databaseName, tableName,
tableInfo)(sparkSession)
+ // Register partitions to hive metastore in case of hive
partitioning carbon table
+ if (tableInfo.getFactTable.getPartitionInfo != null &&
+ tableInfo.getFactTable.getPartitionInfo.getPartitionType ==
PartitionType.NATIVE_HIVE) {
+ registerAllPartitionsToHive(tablePath, databaseName, tableName,
sparkSession)
--- End diff --
ok
---
