Skip to content

Commit 7f66954

Browse files
committed
Address comment
1 parent d2739af commit 7f66954

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

sql/core/src/test/scala/org/apache/spark/sql/execution/python/BatchEvalPythonExecSuite.scala

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -26,6 +26,7 @@ import org.apache.spark.sql.catalyst.FunctionIdentifier
2626
import org.apache.spark.sql.catalyst.expressions.{And, AttributeReference, GreaterThan, In}
2727
import org.apache.spark.sql.execution.{FilterExec, InputAdapter, SparkPlanTest, WholeStageCodegenExec}
2828
import org.apache.spark.sql.functions.col
29+
import org.apache.spark.sql.internal.SQLConf
2930
import org.apache.spark.sql.test.SharedSQLContext
3031
import org.apache.spark.sql.types.BooleanType
3132

@@ -123,8 +124,9 @@ class BatchEvalPythonExecSuite extends SparkPlanTest with SharedSQLContext {
123124
}
124125
assert(errMsg.getMessage.startsWith("Detected implicit cartesian product"))
125126
// Test with spark.sql.crossJoin.enabled=true
126-
spark.conf.set("spark.sql.crossJoin.enabled", "true")
127-
dummyPythonUDFTest()
127+
withSQLConf(SQLConf.CROSS_JOINS_ENABLED.key -> "true") {
128+
dummyPythonUDFTest()
129+
}
128130
}
129131
}
130132

0 commit comments

Comments
 (0)