From 690fece4383b2703ce91a6251e470103f7f3c1de Mon Sep 17 00:00:00 2001 From: Darcy Date: Mon, 2 Dec 2024 16:56:07 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E4=BF=AE=E5=A4=8DSQL=E6=A0=A1=E9=AA=8C?= =?UTF-8?q?=E4=B8=ADSQL=E5=91=BD=E4=BB=A4=E6=B2=A1=E6=9C=89=E6=93=8D?= =?UTF-8?q?=E4=BD=9C=E7=AC=A6=E5=AF=BC=E8=87=B4=E7=9A=84=E7=A9=BA=E6=8C=87?= =?UTF-8?q?=E9=92=88=E5=BC=82=E5=B8=B8=EF=BC=88=E7=9B=AE=E5=89=8D=E6=B5=8B?= =?UTF-8?q?=E8=AF=95=E5=88=B0=E7=9A=84BEGIN=20STATEMENT=20SET=E4=BC=9A?= =?UTF-8?q?=E6=8A=9B=E5=87=BA=E7=A9=BA=E6=8C=87=E9=92=88=E5=BC=82=E5=B8=B8?= =?UTF-8?q?=EF=BC=89?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit (cherry picked from commit 2035fe5036338c099ec92f08680e13d261b6f0f4) --- .../org/apache/streampark/flink/core/FlinkSqlValidator.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 5841d5cd35..96296182d5 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 @@ -81,10 +81,10 @@ private[flink] object FlinkSqlValidator extends Logger { var sqlDialect = "default" var hasInsert = false for (call <- sqlCommands) { - val args = call.operands.head lazy val command = call.command command match { case SET | RESET => + val args = call.operands.head if (command == SET && args == TableConfigOptions.TABLE_SQL_DIALECT.key()) { sqlDialect = call.operands.last }