From 47f50ee2ba1e0458953210fd5e45e93b789766d6 Mon Sep 17 00:00:00 2001
From: ChengJie1053 <18033291053@163.com>
Date: Tue, 24 Oct 2023 15:35:47 +0800
Subject: [PATCH] [Fix] SqlDialect `DEFAULT` requires capitalization (#3277)

* [Fix] sqlDialect "DEFAULT" requires capitalization
---
 .../org/apache/streampark/flink/core/FlinkSqlValidator.scala | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git a/streampark-flink/streampark-flink-shims/streampark-flink-shims-base/src/main/scala/org/apache/streampark/flink/core/FlinkSqlValidator.scala b/streampark-flink/streampark-flink-shims/streampark-flink-shims-base/src/main/scala/org/apache/streampark/flink/core/FlinkSqlValidator.scala
index 417d00adb8..e63c57ea26 100644
--- a/streampark-flink/streampark-flink-shims/streampark-flink-shims-base/src/main/scala/org/apache/streampark/flink/core/FlinkSqlValidator.scala
+++ b/streampark-flink/streampark-flink-shims/streampark-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()))