Github user manishgupta88 commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2876#discussion_r229208346
--- Diff:
integration/spark2/src/main/scala/org/apache/spark/sql/CarbonDictionaryDecoder.scala
---
@@ -137,14 +139,15 @@ case class CarbonDictionaryDecoder(
val forwardDictionaryCache: Cache[DictionaryColumnUniqueIdentifier,
Dictionary] =
cacheProvider.createCache(CacheType.FORWARD_DICTIONARY)
val dicts: Seq[ForwardDictionaryWrapper] =
getDictionaryWrapper(tableNameToCarbonTableMapping,
- forwardDictionaryCache)
+ forwardDictionaryCache, conf)
val exprs = child.output.map { exp =>
ExpressionCanonicalizer.execute(BindReferences.bindReference(exp,
child.output))
}
ctx.currentVars = input
val resultVars = exprs.zipWithIndex.map { case (expr, index) =>
if (dicts(index) != null) {
+
ThreadLocalSessionInfo.setConfigurationToCurrentThread(conf.value.value)
--- End diff --
Remove its usage from this place
---
