From c7b79f060366b7c33682c9e310906953363d2ad2 Mon Sep 17 00:00:00 2001
From: PengFei Li <lpengfei2016@gmail.com>
Date: Mon, 4 Dec 2023 00:21:53 +0800
Subject: [PATCH] [Enhancement] Remove common-compress dependency

Signed-off-by: PengFei Li <lpengfei2016@gmail.com>
---
 .../com/starrocks/connector/flink/catalog/FlinkCatalog.java | 6 +++---
 .../starrocks/connector/flink/catalog/StarRocksCatalog.java | 3 +--
 2 files changed, 4 insertions(+), 5 deletions(-)

diff --git a/src/main/java/com/starrocks/connector/flink/catalog/FlinkCatalog.java b/src/main/java/com/starrocks/connector/flink/catalog/FlinkCatalog.java
index 013abbcc..6fdb5fff 100644
--- a/src/main/java/com/starrocks/connector/flink/catalog/FlinkCatalog.java
+++ b/src/main/java/com/starrocks/connector/flink/catalog/FlinkCatalog.java
@@ -56,7 +56,6 @@
 
 import com.starrocks.connector.flink.table.sink.StarRocksSinkOptions;
 import com.starrocks.connector.flink.table.source.StarRocksSourceOptions;
-import org.apache.commons.compress.utils.Lists;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -66,6 +65,7 @@
 import java.sql.ResultSet;
 import java.sql.SQLException;
 import java.sql.Statement;
+import java.util.ArrayList;
 import java.util.Collections;
 import java.util.HashMap;
 import java.util.HashSet;
@@ -278,7 +278,7 @@ public CatalogBaseTable getTable(ObjectPath tablePath) throws TableNotExistExcep
             properties.putAll(getSourceConfig(tablePath.getDatabaseName(), tablePath.getObjectName()));
             properties.putAll(getSinkConfig(tablePath.getDatabaseName(), tablePath.getObjectName()));
 
-            return CatalogTable.of(flinkSchema, starRocksTable.getComment().orElse(null), Lists.newArrayList(), properties);
+            return CatalogTable.of(flinkSchema, starRocksTable.getComment().orElse(null), new ArrayList<>(), properties);
         } catch (StarRocksCatalogException e) {
             throw new CatalogException(
                     String.format("Failed to get table %s in catalog %s", tablePath.getFullName(), getName()), e);
@@ -387,7 +387,7 @@ private int executeUpdateStatement(String sql) throws SQLException {
     private List<String> executeSingleColumnStatement(String sql, Object... params) {
         try (Connection conn = getConnection();
                 PreparedStatement statement = conn.prepareStatement(sql)) {
-            List<String> columnValues = Lists.newArrayList();
+            List<String> columnValues = new ArrayList<>();
             if (params != null) {
                 for (int i = 0; i < params.length; i++) {
                     statement.setObject(i + 1, params[i]);
diff --git a/src/main/java/com/starrocks/connector/flink/catalog/StarRocksCatalog.java b/src/main/java/com/starrocks/connector/flink/catalog/StarRocksCatalog.java
index 054e3faf..0a8b7790 100644
--- a/src/main/java/com/starrocks/connector/flink/catalog/StarRocksCatalog.java
+++ b/src/main/java/com/starrocks/connector/flink/catalog/StarRocksCatalog.java
@@ -23,7 +23,6 @@
 import org.apache.flink.util.Preconditions;
 import org.apache.flink.util.StringUtils;
 
-import org.apache.commons.compress.utils.Lists;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -453,7 +452,7 @@ private AlterJobState getAlterJobState(String databaseName, String tableName)
     private List<String> executeSingleColumnStatement(String sql) throws SQLException {
         try (Connection conn = getConnection();
                 PreparedStatement statement = conn.prepareStatement(sql)) {
-            List<String> columnValues = Lists.newArrayList();
+            List<String> columnValues = new ArrayList<>();
             try (ResultSet rs = statement.executeQuery()) {
                 while (rs.next()) {
                     String columnValue = rs.getString(1);