This is an automated email from the ASF dual-hosted git repository.
yuqi4733 pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/gravitino.git
The following commit(s) were added to refs/heads/main by this push:
new 1282121dcf [#6907] fix(pg): throw exception when listing table on not
exists schemas in PG catalog (#8243)
1282121dcf is described below
commit 1282121dcf799a8aa50540a5c67963984786a25b
Author: FANNG <[email protected]>
AuthorDate: Tue Aug 26 10:42:48 2025 +0900
[#6907] fix(pg): throw exception when listing table on not exists schemas
in PG catalog (#8243)
### What changes were proposed in this pull request?
throw exception when listing table on not exists schemas in PG catalog
### Why are the changes needed?
Fix: #6907
### Does this PR introduce _any_ user-facing change?
no
### How was this patch tested?
IT
---
.../catalog/jdbc/JdbcCatalogOperations.java | 4 +++
.../jdbc/operation/RequireDatabaseOperation.java | 30 ++++++++++++++++++++++
.../operation/PostgreSqlSchemaOperations.java | 22 ++++++++--------
.../operation/PostgreSqlTableOperations.java | 22 ++++++++++++----
.../postgresql/operation/TestPostgreSql.java | 4 +++
.../operation/TestPostgreSqlTableOperations.java | 1 +
.../connector/integration/test/SparkCommonIT.java | 9 +++----
.../integration/test/hive/SparkHiveCatalogIT.java | 5 ----
.../test/iceberg/SparkIcebergCatalogIT.java | 5 ----
.../test/jdbc/SparkJdbcMysqlCatalogIT.java | 5 ----
.../test/jdbc/SparkJdbcPostgreSqlCatalogIT.java | 4 +--
.../test/paimon/SparkPaimonCatalogIT.java | 5 ----
.../test/jdbc/SparkJdbcPostgreSqlCatalogIT33.java | 2 --
.../test/jdbc/SparkJdbcPostgreSqlCatalogIT34.java | 2 --
.../test/jdbc/SparkJdbcPostgreSqlCatalogIT35.java | 2 --
15 files changed, 72 insertions(+), 50 deletions(-)
diff --git
a/catalogs/catalog-jdbc-common/src/main/java/org/apache/gravitino/catalog/jdbc/JdbcCatalogOperations.java
b/catalogs/catalog-jdbc-common/src/main/java/org/apache/gravitino/catalog/jdbc/JdbcCatalogOperations.java
index 56490d475c..3b318150c7 100644
---
a/catalogs/catalog-jdbc-common/src/main/java/org/apache/gravitino/catalog/jdbc/JdbcCatalogOperations.java
+++
b/catalogs/catalog-jdbc-common/src/main/java/org/apache/gravitino/catalog/jdbc/JdbcCatalogOperations.java
@@ -50,6 +50,7 @@ import
org.apache.gravitino.catalog.jdbc.converter.JdbcTypeConverter;
import org.apache.gravitino.catalog.jdbc.operation.DatabaseOperation;
import org.apache.gravitino.catalog.jdbc.operation.JdbcDatabaseOperations;
import org.apache.gravitino.catalog.jdbc.operation.JdbcTableOperations;
+import org.apache.gravitino.catalog.jdbc.operation.RequireDatabaseOperation;
import org.apache.gravitino.catalog.jdbc.operation.TableOperation;
import org.apache.gravitino.catalog.jdbc.utils.DataSourceUtils;
import org.apache.gravitino.connector.CatalogInfo;
@@ -170,6 +171,9 @@ public class JdbcCatalogOperations implements
CatalogOperations, SupportsSchemas
this.databaseOperation.initialize(dataSource, exceptionConverter,
resultConf);
this.tableOperation.initialize(
dataSource, exceptionConverter, jdbcTypeConverter,
columnDefaultValueConverter, resultConf);
+ if (tableOperation instanceof RequireDatabaseOperation) {
+ ((RequireDatabaseOperation)
tableOperation).setDatabaseOperation(databaseOperation);
+ }
}
/** Closes the Jdbc catalog and releases the associated client pool. */
diff --git
a/catalogs/catalog-jdbc-common/src/main/java/org/apache/gravitino/catalog/jdbc/operation/RequireDatabaseOperation.java
b/catalogs/catalog-jdbc-common/src/main/java/org/apache/gravitino/catalog/jdbc/operation/RequireDatabaseOperation.java
new file mode 100644
index 0000000000..61643b9f91
--- /dev/null
+++
b/catalogs/catalog-jdbc-common/src/main/java/org/apache/gravitino/catalog/jdbc/operation/RequireDatabaseOperation.java
@@ -0,0 +1,30 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+package org.apache.gravitino.catalog.jdbc.operation;
+
+/** Interface marking classes that require a {@link DatabaseOperation}
instance. */
+public interface RequireDatabaseOperation {
+ /**
+ * Sets the {@link DatabaseOperation} instance used for database operations.
+ *
+ * @param databaseOperation The database operation instance to set
+ */
+ void setDatabaseOperation(DatabaseOperation databaseOperation);
+}
diff --git
a/catalogs/catalog-jdbc-postgresql/src/main/java/org/apache/gravitino/catalog/postgresql/operation/PostgreSqlSchemaOperations.java
b/catalogs/catalog-jdbc-postgresql/src/main/java/org/apache/gravitino/catalog/postgresql/operation/PostgreSqlSchemaOperations.java
index 7d24aca29b..2865839512 100644
---
a/catalogs/catalog-jdbc-postgresql/src/main/java/org/apache/gravitino/catalog/postgresql/operation/PostgreSqlSchemaOperations.java
+++
b/catalogs/catalog-jdbc-postgresql/src/main/java/org/apache/gravitino/catalog/postgresql/operation/PostgreSqlSchemaOperations.java
@@ -57,17 +57,7 @@ public class PostgreSqlSchemaOperations extends
JdbcDatabaseOperations {
@Override
public JdbcSchema load(String schema) throws NoSuchSchemaException {
try (Connection connection = getConnection()) {
- ResultSet resultSet = getSchema(connection, schema);
-
- boolean found = false;
- while (resultSet.next()) {
- if (Objects.equals(resultSet.getString(1), schema)) {
- found = true;
- break;
- }
- }
-
- if (!found) {
+ if (!schemaExists(connection, schema)) {
throw new NoSuchSchemaException("No such schema: %s", schema);
}
@@ -171,6 +161,16 @@ public class PostgreSqlSchemaOperations extends
JdbcDatabaseOperations {
return ImmutableSet.of("pg_toast", "pg_catalog", "information_schema");
}
+ public boolean schemaExists(Connection connection, String schema) throws
SQLException {
+ ResultSet resultSet = getSchema(connection, schema);
+ while (resultSet.next()) {
+ if (Objects.equals(resultSet.getString(1), schema)) {
+ return true;
+ }
+ }
+ return false;
+ }
+
private String getShowSchemaCommentSql(String schema) {
return String.format(
"SELECT obj_description(n.oid, 'pg_namespace') AS comment\n"
diff --git
a/catalogs/catalog-jdbc-postgresql/src/main/java/org/apache/gravitino/catalog/postgresql/operation/PostgreSqlTableOperations.java
b/catalogs/catalog-jdbc-postgresql/src/main/java/org/apache/gravitino/catalog/postgresql/operation/PostgreSqlTableOperations.java
index 3b889ee673..852500dbc0 100644
---
a/catalogs/catalog-jdbc-postgresql/src/main/java/org/apache/gravitino/catalog/postgresql/operation/PostgreSqlTableOperations.java
+++
b/catalogs/catalog-jdbc-postgresql/src/main/java/org/apache/gravitino/catalog/postgresql/operation/PostgreSqlTableOperations.java
@@ -45,7 +45,9 @@ import org.apache.gravitino.catalog.jdbc.config.JdbcConfig;
import
org.apache.gravitino.catalog.jdbc.converter.JdbcColumnDefaultValueConverter;
import org.apache.gravitino.catalog.jdbc.converter.JdbcExceptionConverter;
import org.apache.gravitino.catalog.jdbc.converter.JdbcTypeConverter;
+import org.apache.gravitino.catalog.jdbc.operation.DatabaseOperation;
import org.apache.gravitino.catalog.jdbc.operation.JdbcTableOperations;
+import org.apache.gravitino.catalog.jdbc.operation.RequireDatabaseOperation;
import org.apache.gravitino.exceptions.NoSuchColumnException;
import org.apache.gravitino.exceptions.NoSuchSchemaException;
import org.apache.gravitino.exceptions.NoSuchTableException;
@@ -58,7 +60,8 @@ import org.apache.gravitino.rel.indexes.Index;
import org.apache.gravitino.rel.types.Types;
/** Table operations for PostgreSQL. */
-public class PostgreSqlTableOperations extends JdbcTableOperations {
+public class PostgreSqlTableOperations extends JdbcTableOperations
+ implements RequireDatabaseOperation {
public static final String PG_QUOTE = "\"";
public static final String NEW_LINE = "\n";
@@ -72,6 +75,7 @@ public class PostgreSqlTableOperations extends
JdbcTableOperations {
"PostgreSQL does not support nested column names.";
private String database;
+ private PostgreSqlSchemaOperations schemaOperations;
@Override
public void initialize(
@@ -89,17 +93,25 @@ public class PostgreSqlTableOperations extends
JdbcTableOperations {
}
@Override
- public List<String> listTables(String databaseName) throws
NoSuchSchemaException {
- try (Connection connection = getConnection(databaseName)) {
+ public void setDatabaseOperation(DatabaseOperation databaseOperation) {
+ this.schemaOperations = (PostgreSqlSchemaOperations) databaseOperation;
+ }
+
+ @Override
+ public List<String> listTables(String schemaName) throws
NoSuchSchemaException {
+ try (Connection connection = getConnection(schemaName)) {
+ if (!schemaOperations.schemaExists(connection, schemaName)) {
+ throw new NoSuchSchemaException("No such schema: %s", schemaName);
+ }
final List<String> names = Lists.newArrayList();
try (ResultSet tables = getTables(connection)) {
while (tables.next()) {
- if (Objects.equals(tables.getString("TABLE_SCHEM"), databaseName)) {
+ if (Objects.equals(tables.getString("TABLE_SCHEM"), schemaName)) {
names.add(tables.getString("TABLE_NAME"));
}
}
}
- LOG.info("Finished listing tables size {} for database name {} ",
names.size(), databaseName);
+ LOG.info("Finished listing tables size {} for database name {} ",
names.size(), schemaName);
return names;
} catch (final SQLException se) {
throw this.exceptionMapper.toGravitinoException(se);
diff --git
a/catalogs/catalog-jdbc-postgresql/src/test/java/org/apache/gravitino/catalog/postgresql/operation/TestPostgreSql.java
b/catalogs/catalog-jdbc-postgresql/src/test/java/org/apache/gravitino/catalog/postgresql/operation/TestPostgreSql.java
index 0fe04433aa..eda7851b3e 100644
---
a/catalogs/catalog-jdbc-postgresql/src/test/java/org/apache/gravitino/catalog/postgresql/operation/TestPostgreSql.java
+++
b/catalogs/catalog-jdbc-postgresql/src/test/java/org/apache/gravitino/catalog/postgresql/operation/TestPostgreSql.java
@@ -24,6 +24,7 @@ import java.util.HashMap;
import java.util.Map;
import org.apache.gravitino.catalog.jdbc.TestJdbc;
import org.apache.gravitino.catalog.jdbc.config.JdbcConfig;
+import org.apache.gravitino.catalog.jdbc.operation.RequireDatabaseOperation;
import
org.apache.gravitino.catalog.postgresql.converter.PostgreSqlColumnDefaultValueConverter;
import
org.apache.gravitino.catalog.postgresql.converter.PostgreSqlExceptionConverter;
import
org.apache.gravitino.catalog.postgresql.converter.PostgreSqlTypeConverter;
@@ -63,6 +64,9 @@ public class TestPostgreSql extends TestJdbc {
new PostgreSqlTypeConverter(),
new PostgreSqlColumnDefaultValueConverter(),
config);
+ if (TABLE_OPERATIONS instanceof RequireDatabaseOperation) {
+ ((RequireDatabaseOperation)
TABLE_OPERATIONS).setDatabaseOperation(DATABASE_OPERATIONS);
+ }
DATABASE_OPERATIONS.create(TEST_DB_NAME, null, null);
} catch (URISyntaxException e) {
throw new RuntimeException(e);
diff --git
a/catalogs/catalog-jdbc-postgresql/src/test/java/org/apache/gravitino/catalog/postgresql/operation/TestPostgreSqlTableOperations.java
b/catalogs/catalog-jdbc-postgresql/src/test/java/org/apache/gravitino/catalog/postgresql/operation/TestPostgreSqlTableOperations.java
index 723c473d86..5d2d54615a 100644
---
a/catalogs/catalog-jdbc-postgresql/src/test/java/org/apache/gravitino/catalog/postgresql/operation/TestPostgreSqlTableOperations.java
+++
b/catalogs/catalog-jdbc-postgresql/src/test/java/org/apache/gravitino/catalog/postgresql/operation/TestPostgreSqlTableOperations.java
@@ -414,6 +414,7 @@ public class TestPostgreSqlTableOperations extends
TestPostgreSql {
new PostgreSqlTypeConverter(),
new PostgreSqlColumnDefaultValueConverter(),
config);
+ postgreSqlTableOperations.setDatabaseOperation(postgreSqlSchemaOperations);
String table_1 = "table_multiple_1";
postgreSqlTableOperations.create(
diff --git
a/spark-connector/spark-common/src/test/java/org/apache/gravitino/spark/connector/integration/test/SparkCommonIT.java
b/spark-connector/spark-common/src/test/java/org/apache/gravitino/spark/connector/integration/test/SparkCommonIT.java
index 9d8d8fd5da..c74f095dbd 100644
---
a/spark-connector/spark-common/src/test/java/org/apache/gravitino/spark/connector/integration/test/SparkCommonIT.java
+++
b/spark-connector/spark-common/src/test/java/org/apache/gravitino/spark/connector/integration/test/SparkCommonIT.java
@@ -125,9 +125,9 @@ public abstract class SparkCommonIT extends SparkEnvIT {
protected abstract boolean supportsUpdateColumnPosition();
- // @todo temporarily added for:
https://github.com/apache/gravitino/issues/6907, should be removed
- // after the issue is addressed
- protected abstract boolean supportListTable();
+ protected boolean supportsCreateTableWithComment() {
+ return true;
+ }
protected SparkTableInfoChecker getTableInfoChecker() {
return SparkTableInfoChecker.create();
@@ -184,7 +184,6 @@ public abstract class SparkCommonIT extends SparkEnvIT {
}
@Test
- @EnabledIf("supportListTable")
void testListTables() {
String tableName = "t_list";
dropTableIfExists(tableName);
@@ -323,6 +322,7 @@ public abstract class SparkCommonIT extends SparkEnvIT {
}
@Test
+ @EnabledIf("supportsCreateTableWithComment")
void testCreateTableWithComment() {
String tableName = "comment_table";
dropTableIfExists(tableName);
@@ -383,7 +383,6 @@ public abstract class SparkCommonIT extends SparkEnvIT {
}
@Test
- @EnabledIf("supportListTable")
void testListTable() {
String table1 = "list1";
String table2 = "list2";
diff --git
a/spark-connector/spark-common/src/test/java/org/apache/gravitino/spark/connector/integration/test/hive/SparkHiveCatalogIT.java
b/spark-connector/spark-common/src/test/java/org/apache/gravitino/spark/connector/integration/test/hive/SparkHiveCatalogIT.java
index 09d6f902ec..1beacc3853 100644
---
a/spark-connector/spark-common/src/test/java/org/apache/gravitino/spark/connector/integration/test/hive/SparkHiveCatalogIT.java
+++
b/spark-connector/spark-common/src/test/java/org/apache/gravitino/spark/connector/integration/test/hive/SparkHiveCatalogIT.java
@@ -99,11 +99,6 @@ public abstract class SparkHiveCatalogIT extends
SparkCommonIT {
return true;
}
- @Override
- protected boolean supportListTable() {
- return true;
- }
-
@Test
void testCreateHiveFormatPartitionTable() {
String tableName = "hive_partition_table";
diff --git
a/spark-connector/spark-common/src/test/java/org/apache/gravitino/spark/connector/integration/test/iceberg/SparkIcebergCatalogIT.java
b/spark-connector/spark-common/src/test/java/org/apache/gravitino/spark/connector/integration/test/iceberg/SparkIcebergCatalogIT.java
index b595adaf32..0360bea207 100644
---
a/spark-connector/spark-common/src/test/java/org/apache/gravitino/spark/connector/integration/test/iceberg/SparkIcebergCatalogIT.java
+++
b/spark-connector/spark-common/src/test/java/org/apache/gravitino/spark/connector/integration/test/iceberg/SparkIcebergCatalogIT.java
@@ -124,11 +124,6 @@ public abstract class SparkIcebergCatalogIT extends
SparkCommonIT {
return true;
}
- @Override
- protected boolean supportListTable() {
- return true;
- }
-
@Override
protected String getTableLocation(SparkTableInfo table) {
return String.join(File.separator, table.getTableLocation(), "data");
diff --git
a/spark-connector/spark-common/src/test/java/org/apache/gravitino/spark/connector/integration/test/jdbc/SparkJdbcMysqlCatalogIT.java
b/spark-connector/spark-common/src/test/java/org/apache/gravitino/spark/connector/integration/test/jdbc/SparkJdbcMysqlCatalogIT.java
index 60048d0c79..1941aa2522 100644
---
a/spark-connector/spark-common/src/test/java/org/apache/gravitino/spark/connector/integration/test/jdbc/SparkJdbcMysqlCatalogIT.java
+++
b/spark-connector/spark-common/src/test/java/org/apache/gravitino/spark/connector/integration/test/jdbc/SparkJdbcMysqlCatalogIT.java
@@ -76,11 +76,6 @@ public abstract class SparkJdbcMysqlCatalogIT extends
SparkCommonIT {
return true;
}
- @Override
- protected boolean supportListTable() {
- return true;
- }
-
@Override
protected String getCatalogName() {
return "jdbc_mysql";
diff --git
a/spark-connector/spark-common/src/test/java/org/apache/gravitino/spark/connector/integration/test/jdbc/SparkJdbcPostgreSqlCatalogIT.java
b/spark-connector/spark-common/src/test/java/org/apache/gravitino/spark/connector/integration/test/jdbc/SparkJdbcPostgreSqlCatalogIT.java
index d944f315a5..c0615962cd 100644
---
a/spark-connector/spark-common/src/test/java/org/apache/gravitino/spark/connector/integration/test/jdbc/SparkJdbcPostgreSqlCatalogIT.java
+++
b/spark-connector/spark-common/src/test/java/org/apache/gravitino/spark/connector/integration/test/jdbc/SparkJdbcPostgreSqlCatalogIT.java
@@ -26,11 +26,9 @@ import
org.apache.gravitino.integration.test.container.ContainerSuite;
import org.apache.gravitino.spark.connector.integration.test.SparkCommonIT;
import
org.apache.gravitino.spark.connector.integration.test.util.SparkTableInfoChecker;
import org.apache.gravitino.spark.connector.jdbc.JdbcPropertiesConstants;
-import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Tag;
@Tag("gravitino-docker-test")
-@Disabled("Disabled until PG table creation is supported")
public class SparkJdbcPostgreSqlCatalogIT extends SparkCommonIT {
protected String pgUrl;
@@ -79,7 +77,7 @@ public class SparkJdbcPostgreSqlCatalogIT extends
SparkCommonIT {
}
@Override
- protected boolean supportListTable() {
+ protected boolean supportsCreateTableWithComment() {
return false;
}
diff --git
a/spark-connector/spark-common/src/test/java/org/apache/gravitino/spark/connector/integration/test/paimon/SparkPaimonCatalogIT.java
b/spark-connector/spark-common/src/test/java/org/apache/gravitino/spark/connector/integration/test/paimon/SparkPaimonCatalogIT.java
index 975cf7e589..2a395d9a09 100644
---
a/spark-connector/spark-common/src/test/java/org/apache/gravitino/spark/connector/integration/test/paimon/SparkPaimonCatalogIT.java
+++
b/spark-connector/spark-common/src/test/java/org/apache/gravitino/spark/connector/integration/test/paimon/SparkPaimonCatalogIT.java
@@ -78,11 +78,6 @@ public abstract class SparkPaimonCatalogIT extends
SparkCommonIT {
return true;
}
- @Override
- protected boolean supportListTable() {
- return true;
- }
-
@Override
protected boolean supportsReplaceColumns() {
// Paimon doesn't support replace columns, because it doesn't support drop
all fields in table.
diff --git
a/spark-connector/v3.3/spark/src/test/java/org/apache/gravitino/spark/connector/integration/test/jdbc/SparkJdbcPostgreSqlCatalogIT33.java
b/spark-connector/v3.3/spark/src/test/java/org/apache/gravitino/spark/connector/integration/test/jdbc/SparkJdbcPostgreSqlCatalogIT33.java
index c38b6fb9ad..0dba9cde07 100644
---
a/spark-connector/v3.3/spark/src/test/java/org/apache/gravitino/spark/connector/integration/test/jdbc/SparkJdbcPostgreSqlCatalogIT33.java
+++
b/spark-connector/v3.3/spark/src/test/java/org/apache/gravitino/spark/connector/integration/test/jdbc/SparkJdbcPostgreSqlCatalogIT33.java
@@ -20,10 +20,8 @@ package
org.apache.gravitino.spark.connector.integration.test.jdbc;
import
org.apache.gravitino.spark.connector.jdbc.postgresql.GravitinoPostgreSqlCatalogSpark33;
import org.junit.jupiter.api.Assertions;
-import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Test;
-@Disabled("Disabled until PG table creation is supported")
public class SparkJdbcPostgreSqlCatalogIT33 extends
SparkJdbcPostgreSqlCatalogIT {
@Test
diff --git
a/spark-connector/v3.4/spark/src/test/java/org/apache/gravitino/spark/connector/integration/test/jdbc/SparkJdbcPostgreSqlCatalogIT34.java
b/spark-connector/v3.4/spark/src/test/java/org/apache/gravitino/spark/connector/integration/test/jdbc/SparkJdbcPostgreSqlCatalogIT34.java
index 836bde5da1..f394ae96a4 100644
---
a/spark-connector/v3.4/spark/src/test/java/org/apache/gravitino/spark/connector/integration/test/jdbc/SparkJdbcPostgreSqlCatalogIT34.java
+++
b/spark-connector/v3.4/spark/src/test/java/org/apache/gravitino/spark/connector/integration/test/jdbc/SparkJdbcPostgreSqlCatalogIT34.java
@@ -20,10 +20,8 @@ package
org.apache.gravitino.spark.connector.integration.test.jdbc;
import
org.apache.gravitino.spark.connector.jdbc.postgresql.GravitinoPostgreSqlCatalogSpark34;
import org.junit.jupiter.api.Assertions;
-import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Test;
-@Disabled("Disabled until PG table creation is supported")
public class SparkJdbcPostgreSqlCatalogIT34 extends
SparkJdbcPostgreSqlCatalogIT {
@Test
diff --git
a/spark-connector/v3.5/spark/src/test/java/org/apache/gravitino/spark/connector/integration/test/jdbc/SparkJdbcPostgreSqlCatalogIT35.java
b/spark-connector/v3.5/spark/src/test/java/org/apache/gravitino/spark/connector/integration/test/jdbc/SparkJdbcPostgreSqlCatalogIT35.java
index 893b98cc71..f99bc32890 100644
---
a/spark-connector/v3.5/spark/src/test/java/org/apache/gravitino/spark/connector/integration/test/jdbc/SparkJdbcPostgreSqlCatalogIT35.java
+++
b/spark-connector/v3.5/spark/src/test/java/org/apache/gravitino/spark/connector/integration/test/jdbc/SparkJdbcPostgreSqlCatalogIT35.java
@@ -20,10 +20,8 @@ package
org.apache.gravitino.spark.connector.integration.test.jdbc;
import
org.apache.gravitino.spark.connector.jdbc.postgresql.GravitinoPostgreSqlCatalogSpark35;
import org.junit.jupiter.api.Assertions;
-import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Test;
-@Disabled("Disabled until PG table creation is supported")
public class SparkJdbcPostgreSqlCatalogIT35 extends
SparkJdbcPostgreSqlCatalogIT {
@Test
