Github user gvramana commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2484#discussion_r201612604
--- Diff:
integration/spark-common/src/main/scala/org/apache/carbondata/spark/rdd/NewCarbonDataLoadRDD.scala
---
@@ -262,9 +223,9 @@ class NewCarbonDataLoadRDD[K, V](
def getInputIterators: Array[CarbonIterator[Array[AnyRef]]] = {
val attemptId = new TaskAttemptID(jobTrackerId, id, TaskType.MAP,
theSplit.index, 0)
- var configuration: Configuration = getConf
+ var configuration: Configuration = CarbonRDD.getConf
if (configuration == null) {
- configuration = new Configuration()
+ configuration = CarbonRDD.getConf
--- End diff --
it should be new Configuration
---
