diff --git a/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/GenericInMemoryCatalog.java b/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/GenericInMemoryCatalog.java index 29e87a5bad4d3..0c901c84c79b6 100644 --- a/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/GenericInMemoryCatalog.java +++ b/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/GenericInMemoryCatalog.java @@ -117,7 +117,7 @@ public void dropDatabase(String databaseName, boolean ignoreIfNotExists, boolean if (isDatabaseEmpty(databaseName)) { databases.remove(databaseName); } else if (cascade) { - // delete all tables in this database and then delete the database. + // delete all tables and functions in this database and then delete the database. List deleteTablePaths = tables.keySet().stream() .filter(op -> op.getDatabaseName().equals(databaseName)).collect(Collectors.toList()); deleteTablePaths.forEach(objectPath -> {