This is an automated email from the ASF dual-hosted git repository.
benjobs pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git
The following commit(s) were added to refs/heads/dev by this push:
new 47f50ee2b [Fix] SqlDialect `DEFAULT` requires capitalization (#3277)
47f50ee2b is described below
commit 47f50ee2ba1e0458953210fd5e45e93b789766d6
Author: ChengJie1053 <[email protected]>
AuthorDate: Tue Oct 24 15:35:47 2023 +0800
[Fix] SqlDialect `DEFAULT` requires capitalization (#3277)
* [Fix] sqlDialect "DEFAULT" requires capitalization
---
.../scala/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 417d00adb..e63c57ea2 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()))
