[hotfix] Fix the comment about dropping database in in-memory catalog

silenceland · Dec 4, 2019 · 6d677fb · 6d677fb
1 parent 02a8c41
commit 6d677fb
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...k-table-api-java/src/main/java/org/apache/flink/table/catalog/GenericInMemoryCatalog.java b/...k-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<ObjectPath> deleteTablePaths = tables.keySet().stream()
 						.filter(op -> op.getDatabaseName().equals(databaseName)).collect(Collectors.toList());
 				deleteTablePaths.forEach(objectPath -> {