Merge pull request #328 from hjafarpour/KSQL-376-droptable-issue

Fixed the drop table issue.
confluentinc · Sep 30, 2017 · dc1ad22 · dc1ad22
2 parents f2a1a9f + bbf636d
commit dc1ad22
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/ksql-rest-app/src/main/java/io/confluent/ksql/rest/server/resources/KsqlResource.java b/ksql-rest-app/src/main/java/io/confluent/ksql/rest/server/resources/KsqlResource.java
@@ -398,6 +398,12 @@ private void registerDdlCommandTasks() {
       return statement.toString();
     });
 
+    ddlCommandTasks.put(DropTable.class, (statement, statementText, properties) -> {
+      DropSourceCommand dropSourceCommand = new DropSourceCommand((DropTable) statement);
+      new DDLCommandExec(ksqlEngine.getMetaStore().clone()).execute(dropSourceCommand);
+      return statement.toString();
+    });
+
     ddlCommandTasks.put(TerminateQuery.class, (statement, statementText, properties) -> statement.toString());
   }