diff --git a/native-sql-engine/core/src/main/scala/com/intel/oap/expression/ColumnarDateTimeExpressions.scala b/native-sql-engine/core/src/main/scala/com/intel/oap/expression/ColumnarDateTimeExpressions.scala index a2908f4fc..4f4884654 100644 --- a/native-sql-engine/core/src/main/scala/com/intel/oap/expression/ColumnarDateTimeExpressions.scala +++ b/native-sql-engine/core/src/main/scala/com/intel/oap/expression/ColumnarDateTimeExpressions.scala @@ -518,6 +518,13 @@ object ColumnarDateTimeExpressions { buildCheck() def buildCheck(): Unit = { + val parserPolicy = SQLConf.get.getConf(SQLConf.LEGACY_TIME_PARSER_POLICY); + // TODO: support "exception" time parser policy. + if (!parserPolicy.equalsIgnoreCase("corrected")) { + throw new UnsupportedOperationException( + s"$parserPolicy is NOT a supported time parser policy"); + } + val supportedTypes = List(StringType) if (supportedTypes.indexOf(left.dataType) == -1) { throw new UnsupportedOperationException(