danny0405 commented on a change in pull request #13037:
URL: https://github.com/apache/flink/pull/13037#discussion_r463531202
##########
File path:
flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/api/TableEnvironmentTest.scala
##########
@@ -135,6 +135,82 @@ class TableEnvironmentTest {
.tableExists(ObjectPath.fromString(s"${tableEnv.getCurrentDatabase}.tbl1")))
}
+ @Test
+ def testExecuteSqlWithCreateTableAlterDropIfNotExists(): Unit = {
+ val createTableStmt =
+ """
+ |CREATE TABLE IF NOT EXISTS tbl1 (
+ | a bigint,
+ | b int,
+ | c varchar
+ |) with (
+ | 'connector' = 'COLLECTION',
+ | 'is-bounded' = 'false'
+ |)
+ """.stripMargin
+ val tableResult1 = tableEnv.executeSql(createTableStmt)
+ assertEquals(ResultKind.SUCCESS, tableResult1.getResultKind)
+ assertTrue(tableEnv.getCatalog(tableEnv.getCurrentCatalog).get()
+
.tableExists(ObjectPath.fromString(s"${tableEnv.getCurrentDatabase}.tbl1")))
+
+ val tableResult2 = tableEnv.executeSql("ALTER TABLE tbl1 SET ('k1' = 'a',
'k2' = 'b')")
+ assertEquals(ResultKind.SUCCESS, tableResult2.getResultKind)
+ assertEquals(
Review comment:
The `ALTER TABLE tbl1 SET` is not necessary, we can merge the test
`testExecuteSqlWithCreateTableIfNotExistsTwice` into this one.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
