Skip to content

Commit 62ffc63

Browse files
committed
Fix DROP IF NOT EXISTS statement
1 parent 53a0d3c commit 62ffc63

File tree

1 file changed

+4
-2
lines changed
  • sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/parser

1 file changed

+4
-2
lines changed

sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/parser/SqlDropObject.java

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -74,8 +74,10 @@ public void execute(CalcitePrepare.Context context) {
7474
case DROP_TABLE:
7575
if (schema.schema instanceof BeamCalciteSchema) {
7676
BeamCalciteSchema beamSchema = (BeamCalciteSchema) schema.schema;
77-
beamSchema.getTableProvider().dropTable(name.getSimple());
78-
existed = true;
77+
existed = beamSchema.getTableProvider().getTable(name.getSimple()) != null;
78+
if (existed) {
79+
beamSchema.getTableProvider().dropTable(name.getSimple());
80+
}
7981
} else {
8082
existed = schema.removeTable(name.getSimple());
8183
}

0 commit comments

Comments
 (0)