Commit d701b06 1 parent ba81cac commit d701b06 Copy full SHA for d701b06
File tree 2 files changed +4
-2
lines changed
gluten-core/src/main/scala/org/apache/gluten/extension
2 files changed +4
-2
lines changed Original file line number Diff line number Diff line change @@ -21,6 +21,7 @@ import org.apache.gluten.extension.caller.CallerInfo
21
21
22
22
import org .apache .spark .sql .SparkSession
23
23
import org .apache .spark .sql .execution .SparkPlan
24
+ import org .apache .spark .sql .internal .SQLConf
24
25
25
26
trait ColumnarRuleApplier {
26
27
def apply (plan : SparkPlan , outputsColumnar : Boolean ): SparkPlan
@@ -32,7 +33,7 @@ object ColumnarRuleApplier {
32
33
val caller : CallerInfo ,
33
34
val outputsColumnar : Boolean ) {
34
35
val glutenConf : GlutenConfig = {
35
- new GlutenConfig (session.sessionState.conf )
36
+ new GlutenConfig (SQLConf .get )
36
37
}
37
38
}
38
39
}
Original file line number Diff line number Diff line change @@ -29,6 +29,7 @@ import org.apache.spark.internal.Logging
29
29
import org .apache .spark .sql .{SparkSession , SparkSessionExtensions }
30
30
import org .apache .spark .sql .catalyst .rules .Rule
31
31
import org .apache .spark .sql .execution .SparkPlan
32
+ import org .apache .spark .sql .internal .SQLConf
32
33
33
34
import scala .collection .mutable
34
35
@@ -44,7 +45,7 @@ class GlutenInjector private[injector] (control: InjectorControl) {
44
45
}
45
46
46
47
private def applier (session : SparkSession ): ColumnarRuleApplier = {
47
- val conf = new GlutenConfig (session.sessionState.conf )
48
+ val conf = new GlutenConfig (SQLConf .get )
48
49
if (conf.enableRas) {
49
50
return ras.createApplier(session)
50
51
}
You can’t perform that action at this time.
0 commit comments