(seatunnel-web) branch main updated: [Bug] [Seatunnel-web] [HiveJDBC] Duplicate columns are displayed in source (#221)

[fanjia]

This is an automated email from the ASF dual-hosted git repository.

fanjia pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/seatunnel-web.git


The following commit(s) were added to refs/heads/main by this push:
     new 033a4b39 [Bug] [Seatunnel-web] [HiveJDBC] Duplicate columns are 
displayed in source (#221)
033a4b39 is described below

commit 033a4b397edfacfb8fef98b7563e72729da99296
Author: Mohammad Arshad <ars...@apache.org>
AuthorDate: Sun Oct 6 12:35:42 2024 +0530

    [Bug] [Seatunnel-web] [HiveJDBC] Duplicate columns are displayed in source 
(#221)
---
 .../datasource/plugin/hive/jdbc/HiveJdbcDataSourceChannel.java      | 6 ++----
 1 file changed, 2 insertions(+), 4 deletions(-)

diff --git 
a/seatunnel-datasource/seatunnel-datasource-plugins/datasource-jdbc-hive/src/main/java/org/apache/seatunnel/datasource/plugin/hive/jdbc/HiveJdbcDataSourceChannel.java
 
b/seatunnel-datasource/seatunnel-datasource-plugins/datasource-jdbc-hive/src/main/java/org/apache/seatunnel/datasource/plugin/hive/jdbc/HiveJdbcDataSourceChannel.java
index 1e62fa59..c56b9d82 100644
--- 
a/seatunnel-datasource/seatunnel-datasource-plugins/datasource-jdbc-hive/src/main/java/org/apache/seatunnel/datasource/plugin/hive/jdbc/HiveJdbcDataSourceChannel.java
+++ 
b/seatunnel-datasource/seatunnel-datasource-plugins/datasource-jdbc-hive/src/main/java/org/apache/seatunnel/datasource/plugin/hive/jdbc/HiveJdbcDataSourceChannel.java
@@ -179,9 +179,7 @@ public class HiveJdbcDataSourceChannel implements 
DataSourceChannel {
         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 @@ public class HiveJdbcDataSourceChannel implements 
DataSourceChannel {
         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");