Github user kumarvishal09 commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/3029#discussion_r244721762
--- Diff:
integration/spark-common/src/main/scala/org/apache/carbondata/spark/rdd/StreamHandoffRDD.scala
---
@@ -118,7 +118,7 @@ class StreamHandoffRDD[K, V](
CommonUtil.setTempStoreLocation(split.index, carbonLoadModel, true,
false)
// use CompactionResultSortProcessor to sort data dan write to
columnar files
val processor = prepareHandoffProcessor(carbonTable)
- val status = processor.execute(iteratorList)
+ val status = processor.execute(iteratorList, null)
--- End diff --
Please add comment why need to pass null
---
