commit.

s7monk · Jul 9, 2024 · b76b5d5 · b76b5d5
1 parent d90734e
commit b76b5d5
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 0 deletions.
diff --git a/paimon-web-server/pom.xml b/paimon-web-server/pom.xml
@@ -37,6 +37,7 @@ under the License.
     <properties>
         <hadoop.version>2.8.5</hadoop.version>
         <flink.version>1.18.1</flink.version>
+        <scala.version>2.12</scala.version>
     </properties>
 
     <dependencies>
@@ -247,6 +248,13 @@ under the License.
             </exclusions>
         </dependency>
 
+        <dependency>
+            <groupId>org.apache.flink</groupId>
+            <artifactId>flink-table-planner_${scala.version}</artifactId>
+            <version>${flink.version}</version>
+            <scope>test</scope>
+        </dependency>
+
         <dependency>
             <groupId>commons-cli</groupId>
             <artifactId>commons-cli</artifactId>

diff --git a/...n-web-server/src/test/java/org/apache/paimon/web/server/controller/JobControllerTest.java b/...n-web-server/src/test/java/org/apache/paimon/web/server/controller/JobControllerTest.java
@@ -113,6 +113,7 @@ public void before() throws Exception {
                         .port(port)
                         .enabled(true)
                         .type("Flink")
+                        .deploymentMode("flink-sql-gateway")
                         .build();
         boolean res = clusterService.save(cluster);
         assertTrue(res);

diff --git a/...b-server/src/test/java/org/apache/paimon/web/server/controller/SessionControllerTest.java b/...b-server/src/test/java/org/apache/paimon/web/server/controller/SessionControllerTest.java
@@ -123,6 +123,7 @@ public void testCreateSession() throws Exception {
                         .port(port)
                         .enabled(true)
                         .type("Flink")
+                        .deploymentMode("flink-sql-gateway")
                         .build();
         boolean res = clusterService.save(cluster);
         assertTrue(res);