diff --git a/integration/spark/src/main/scala/org/apache/spark/sql/CarbonEnv.scala b/integration/spark/src/main/scala/org/apache/spark/sql/CarbonEnv.scala index bb6e2ef7078..4cac9c5cc32 100644 --- a/integration/spark/src/main/scala/org/apache/spark/sql/CarbonEnv.scala +++ b/integration/spark/src/main/scala/org/apache/spark/sql/CarbonEnv.scala @@ -394,7 +394,7 @@ object CarbonEnv { tmpPath = tmpPath + "_" + tableId } val path = new Path(tmpPath) - val fs = path.getFileSystem(sparkSession.sparkContext.hadoopConfiguration) + val fs = path.getFileSystem(sparkSession.sessionState.newHadoopConf()) fs.makeQualified(path).toString }