[Bug] [Seatunnel-web] [HiveJDBC] Duplicate columns are displayed in s…

…ource (#221)
apache · Oct 6, 2024 · 033a4b3 · 033a4b3
1 parent 1545c3b
commit 033a4b3
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/...main/java/org/apache/seatunnel/datasource/plugin/hive/jdbc/HiveJdbcDataSourceChannel.java b/...main/java/org/apache/seatunnel/datasource/plugin/hive/jdbc/HiveJdbcDataSourceChannel.java
@@ -179,9 +179,7 @@ protected List<String> getTableNames(Map<String, String> requestParams, String d
         List<String> tableNames = new ArrayList<>();
         try (Connection connection = getHiveConnection(requestParams)) {
             ResultSet resultSet =
-                    connection
-                            .getMetaData()
-                            .getTables(dbName, dbName, null, new String[] {"TABLE"});
+                    connection.getMetaData().getTables(null, dbName, null, new String[] {"TABLE"});
             while (resultSet.next()) {
                 String tableName = resultSet.getString("TABLE_NAME");
                 if (StringUtils.isNotBlank(tableName)) {
@@ -200,7 +198,7 @@ protected List<TableField> getTableFields(
         try (Connection connection = getHiveConnection(requestParams)) {
             DatabaseMetaData metaData = connection.getMetaData();
             String primaryKey = getPrimaryKey(metaData, dbName, tableName);
-            ResultSet resultSet = metaData.getColumns(dbName, null, tableName, null);
+            ResultSet resultSet = metaData.getColumns(null, dbName, tableName, null);
             while (resultSet.next()) {
                 TableField tableField = new TableField();
                 String columnName = resultSet.getString("COLUMN_NAME");