wuchong commented on a change in pull request #9092: [FLINK-13211] Add drop
table support for flink planner
URL: https://github.com/apache/flink/pull/9092#discussion_r302565654
##########
File path:
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/catalog/CatalogTableITCase.scala
##########
@@ -440,6 +440,99 @@ class CatalogTableITCase(isStreaming: Boolean) {
execJob("testJob")
assertEquals(TestCollectionTableFactory.RESULT.sorted, sourceData.sorted)
}
+
+ @Test
+ def testDropTableWithFullPath(): Unit = {
+ val ddl1 =
+ """
+ |create table t1(
+ | a bigint,
+ | b bigint,
+ | c varchar
+ |) with (
+ | connector = 'COLLECTION'
+ |)
+ """.stripMargin
+ val ddl2 =
+ """
+ |create table t2(
+ | a bigint,
+ | b bigint
+ |) with (
+ | connector = 'COLLECTION'
+ |)
+ """.stripMargin
+
+ tableEnv.sqlUpdate(ddl1)
+ tableEnv.sqlUpdate(ddl2)
+ tableEnv.sqlUpdate("DROP TABLE default_catalog.default_database.t2")
Review comment:
assert we have t1 and t2 before drop
----------------------------------------------------------------
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:
[email protected]
With regards,
Apache Git Services
