diff --git a/sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/parser/SqlAlterCatalog.java b/sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/parser/SqlAlterCatalog.java index a67b5f892420..8e5bc3e40f47 100644 --- a/sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/parser/SqlAlterCatalog.java +++ b/sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/parser/SqlAlterCatalog.java @@ -101,11 +101,6 @@ public void execute(CalcitePrepare.Context context) { @Override public void unparseAlterOperation(SqlWriter writer, int left, int right) { - unparse(writer, left, right); - } - - @Override - public void unparse(SqlWriter writer, int left, int right) { writer.keyword("ALTER"); writer.keyword("CATALOG"); name.unparse(writer, left, right); diff --git a/sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/parser/SqlAlterTable.java b/sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/parser/SqlAlterTable.java index 4c4fa4f8f1de..32a86864bcb6 100644 --- a/sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/parser/SqlAlterTable.java +++ b/sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/parser/SqlAlterTable.java @@ -154,11 +154,6 @@ private void validateNonOverlappingProps( @Override public void unparseAlterOperation(SqlWriter writer, int left, int right) { - unparse(writer, left, right); - } - - @Override - public void unparse(SqlWriter writer, int left, int right) { writer.keyword("ALTER"); writer.keyword("TABLE"); name.unparse(writer, left, right);