[improve](catalog) improve code (apache#222)

JNSimba · Nov 1, 2023 · 115017b · 115017b
1 parent c9e2751
commit 115017b
Showing 1 changed file with 4 additions and 5 deletions.
diff --git a/flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DorisSystem.java b/flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DorisSystem.java
@@ -24,7 +24,6 @@
 import org.apache.doris.flink.exception.CreateTableException;
 import org.apache.doris.flink.exception.DorisRuntimeException;
 import org.apache.doris.flink.exception.DorisSystemException;
-import org.apache.doris.flink.tools.cdc.DatabaseSync;
 import org.apache.flink.annotation.Public;
 import org.apache.flink.util.StringUtils;
 import org.slf4j.Logger;
@@ -33,7 +32,7 @@
 import java.sql.PreparedStatement;
 import java.sql.ResultSet;
 import java.sql.Statement;
-import java.util.Arrays;
+import java.util.Collections;
 import java.util.List;
 import java.util.Map;
 import java.util.Objects;
@@ -47,9 +46,9 @@
  */
 @Public
 public class DorisSystem {
-    private static final Logger LOG = LoggerFactory.getLogger(DatabaseSync.class);
-    private JdbcConnectionProvider jdbcConnectionProvider;
-    private static final List<String> builtinDatabases = Arrays.asList("information_schema");
+    private static final Logger LOG = LoggerFactory.getLogger(DorisSystem.class);
+    private final JdbcConnectionProvider jdbcConnectionProvider;
+    private static final List<String> builtinDatabases = Collections.singletonList("information_schema");
 
     public DorisSystem(DorisConnectionOptions options) {
         this.jdbcConnectionProvider = new SimpleJdbcConnectionProvider(options);