fsk119 commented on code in PR #19846:
URL: https://github.com/apache/flink/pull/19846#discussion_r913336031
##
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/operation/OperationExecutor.java:
##
@@ -0,0 +1,172 @@
+/*
+ * Licensed to the Apach
fsk119 commented on code in PR #19846:
URL: https://github.com/apache/flink/pull/19846#discussion_r913338177
##
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/operation/OperationExecutor.java:
##
@@ -0,0 +1,172 @@
+/*
+ * Licensed to the Apach
fsk119 commented on code in PR #19846:
URL: https://github.com/apache/flink/pull/19846#discussion_r913345494
##
flink-table/flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/service/SqlGatewayServiceStatementITCase.java:
##
@@ -0,0 +1,294 @@
+/*
+ * Licensed to the
fsk119 commented on code in PR #19846:
URL: https://github.com/apache/flink/pull/19846#discussion_r913350238
##
flink-table/flink-sql-gateway/src/test/resources/sql/insert.q:
##
@@ -0,0 +1,182 @@
+# insert.q - insert
Review Comment:
Currently only `ADD JAR/REMOVE JAR/STATEME
fsk119 commented on code in PR #19846:
URL: https://github.com/apache/flink/pull/19846#discussion_r913351720
##
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/operation/OperationExecutor.java:
##
@@ -0,0 +1,172 @@
+/*
+ * Licensed to the Apach
fsk119 commented on code in PR #19846:
URL: https://github.com/apache/flink/pull/19846#discussion_r913352482
##
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/result/ResultStore.java:
##
@@ -37,6 +37,13 @@ public class ResultStore {
pri
fsk119 commented on code in PR #19846:
URL: https://github.com/apache/flink/pull/19846#discussion_r913501319
##
flink-table/flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/service/utils/SqlGatewayServiceExtension.java:
##
@@ -43,6 +47,15 @@ public class SqlGateway
fsk119 commented on code in PR #19846:
URL: https://github.com/apache/flink/pull/19846#discussion_r913520517
##
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/operation/OperationExecutor.java:
##
@@ -0,0 +1,178 @@
+/*
+ * Licensed to the Apach
fsk119 commented on code in PR #19846:
URL: https://github.com/apache/flink/pull/19846#discussion_r913713918
##
flink-table/flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/service/context/SessionContextTest.java:
##
@@ -0,0 +1,148 @@
+/*
+ * Licensed to the Apache