[HOTFIX] Fixed sk/ak not found for datasource table

Fixed sk/ak not found for datasource table This closes #3326
apache · Jul 22, 2019 · c0d8d34 · c0d8d34
1 parent ec2a731
commit c0d8d34
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...rc/main/scala/org/apache/spark/sql/carbondata/execution/datasources/CarbonFileIndex.scala b/...rc/main/scala/org/apache/spark/sql/carbondata/execution/datasources/CarbonFileIndex.scala
@@ -35,7 +35,7 @@ import org.apache.carbondata.core.datastore.filesystem.{CarbonFile, HDFSCarbonFi
 import org.apache.carbondata.core.readcommitter.LatestFilesReadCommittedScope
 import org.apache.carbondata.core.scan.expression.{Expression => CarbonExpression}
 import org.apache.carbondata.core.scan.expression.logical.AndExpression
-import org.apache.carbondata.core.util.CarbonProperties
+import org.apache.carbondata.core.util.{CarbonProperties, ThreadLocalSessionInfo}
 import org.apache.carbondata.core.util.path.CarbonTablePath
 import org.apache.carbondata.hadoop.CarbonInputSplit
 import org.apache.carbondata.hadoop.api.{CarbonFileInputFormat, CarbonInputFormat}
@@ -95,6 +95,7 @@ class CarbonFileIndex(
     val tablePath = parameters.get("path")
     if (tablePath.nonEmpty && dataFilters.nonEmpty) {
       val hadoopConf = sparkSession.sessionState.newHadoopConf()
+      ThreadLocalSessionInfo.setConfigurationToCurrentThread(hadoopConf)
       // convert t sparks source filter
       val filters = dataFilters.flatMap(DataSourceStrategy.translateFilter)
       val dataTypeMap = dataSchema.map(f => f.name -> f.dataType).toMap