Github user QiangCai commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1317#discussion_r137916597
--- Diff:
integration/spark-common/src/main/scala/org/apache/carbondata/spark/rdd/AlterTableLoadPartitionRDD.scala
---
@@ -104,20 +103,20 @@ class AlterTableSplitPartitionRDD[K, V](
true
)
- val splitStatus = if (rows.isEmpty) {
+ val loadStatus = if (rows.isEmpty) {
LOGGER.info("After repartition this split, NO target rows
to write back.")
true
} else {
+ val segmentProperties =
PartitionUtils.getSegmentProperties(identifier,
+ segmentId, partitionIds.toList, oldPartitionIdList,
partitionInfo)
+ val processor = new RowResultProcessor(
+ carbonTable,
+ carbonLoadModel,
+ segmentProperties,
+ tempStoreLoc,
+ bucketId
+ )
--- End diff --
move to last line
---
