Skip to content

Commit b7c6baf

Browse files
committed
throw exception for PostgreCastToBoolean.ansiEnabled
1 parent 36f60ee commit b7c6baf

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/postgreSQL/PostgreCastToBoolean.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -20,14 +20,14 @@ import org.apache.spark.sql.catalyst.analysis.TypeCheckResult
2020
import org.apache.spark.sql.catalyst.expressions.{CastBase, Expression, TimeZoneAwareExpression}
2121
import org.apache.spark.sql.catalyst.expressions.codegen.Block._
2222
import org.apache.spark.sql.catalyst.util.postgreSQL.StringUtils
23-
import org.apache.spark.sql.internal.SQLConf
2423
import org.apache.spark.sql.types._
2524
import org.apache.spark.unsafe.types.UTF8String
2625

2726
case class PostgreCastToBoolean(child: Expression, timeZoneId: Option[String])
2827
extends CastBase {
2928

30-
override protected def ansiEnabled = SQLConf.get.ansiEnabled
29+
override protected def ansiEnabled =
30+
throw new UnsupportedOperationException("PostgreSQL dialect doesn't support ansi mode")
3131

3232
override def withTimeZone(timeZoneId: String): TimeZoneAwareExpression =
3333
copy(timeZoneId = Option(timeZoneId))

0 commit comments

Comments
 (0)