fix

snuyanzin · Aug 14, 2024 · 0aec982 · 0aec982
1 parent 1cdbc2a
commit 0aec982
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/.../flink-table-planner/src/test/scala/org/apache/flink/table/api/TableEnvironmentTest.scala b/.../flink-table-planner/src/test/scala/org/apache/flink/table/api/TableEnvironmentTest.scala
@@ -1491,14 +1491,14 @@ class TableEnvironmentTest {
 
     val createTableStmt =
       """
-        |CREATE TABLE catalog1.db1.view1 AS SELECT 1, 'abc'
+        |CREATE VIEW catalog1.db1.view1 AS SELECT 1, 'abc'
       """.stripMargin
     val tableResult1 = tableEnv.executeSql(createTableStmt)
     assertEquals(ResultKind.SUCCESS, tableResult1.getResultKind)
 
     val createTableStmt2 =
       """
-        |CREATE TABLE catalog1.db1.view2 AS SELECT 123
+        |CREATE VIEW catalog1.db1.view2 AS SELECT 123
       """.stripMargin
     val tableResult2 = tableEnv.executeSql(createTableStmt2)
     assertEquals(ResultKind.SUCCESS, tableResult2.getResultKind)