Github user kunal642 commented on a diff in the pull request:

    https://github.com/apache/carbondata/pull/2484#discussion_r203263435
  
    --- Diff: 
integration/spark-common/src/main/scala/org/apache/carbondata/spark/rdd/CarbonRDD.scala
 ---
    @@ -79,14 +66,11 @@ abstract class CarbonRDD[T: ClassTag](@transient sc: 
SparkContext,
       }
     
       def getConf: Configuration = {
    -    val configuration = new Configuration(false)
    -    val bai = new 
ByteArrayInputStream(CompressorFactory.getInstance().getCompressor
    -      .unCompressByte(confBytes))
    -    val ois = new ObjectInputStream(bai)
    -    configuration.readFields(ois)
    -    ois.close()
    -    configuration
    +    val carbonConfiguration = 
carbonSessionInfo.getThreadParams.getExtraInfo("carbonConf")
    --- End diff --
    
    done


---

Reply via email to