Github user jackylk commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1424#discussion_r147552684
--- Diff:
integration/spark-common/src/main/scala/org/apache/carbondata/spark/rdd/CarbonIUDMergerRDD.scala
---
@@ -59,18 +59,8 @@ class CarbonIUDMergerRDD[K, V](
val jobConf: JobConf = new JobConf(new Configuration)
val job: Job = new Job(jobConf)
val format =
CarbonInputFormatUtil.createCarbonInputFormat(absoluteTableIdentifier, job)
- var defaultParallelism = sparkContext.defaultParallelism
- val result = new util.ArrayList[Partition](defaultParallelism)
-
- // mapping of the node and block list.
- var nodeMapping: util.Map[String, util.List[Distributable]] = new
- util.HashMap[String, util.List[Distributable]]
-
- var noOfBlocks = 0
-
- val taskInfoList = new util.ArrayList[Distributable]
-
- var blocksOfLastSegment: List[TableBlockInfo] = null
--- End diff --
All these variables are not used
---
