[Fix] SqlDialect DEFAULT requires capitalization (#3277)

* [Fix] sqlDialect "DEFAULT" requires capitalization
apache · Oct 24, 2023 · 47f50ee · 47f50ee
1 parent a8abc4a
commit 47f50ee
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/...-flink-shims-base/src/main/scala/org/apache/streampark/flink/core/FlinkSqlValidator.scala b/...-flink-shims-base/src/main/scala/org/apache/streampark/flink/core/FlinkSqlValidator.scala
@@ -16,9 +16,8 @@
  */
 package org.apache.streampark.flink.core
 
-import org.apache.streampark.common.Constant
 import org.apache.streampark.common.enums.FlinkSqlValidationFailedType
-import org.apache.streampark.common.util.{ExceptionUtils, Logger, Utils}
+import org.apache.streampark.common.util.{ExceptionUtils, Logger}
 import org.apache.streampark.flink.core.SqlCommand._
 
 import org.apache.calcite.config.Lex
@@ -84,7 +83,7 @@ object FlinkSqlValidator extends Logger {
               .getOrElse(Class.forName(FLINK113_PLUS_CALCITE_PARSER_CLASS))
             sqlDialect.toUpperCase() match {
               case "HIVE" =>
-              case Constant.DEFAULT =>
+              case "DEFAULT" =>
                 val parser = calciteClass
                   .getConstructor(Array(classOf[Config]): _*)
                   .newInstance(sqlParserConfigMap(sqlDialect.toUpperCase()))