This is an automated email from the ASF dual-hosted git repository.
diwu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris-flink-connector.git
The following commit(s) were added to refs/heads/master by this push:
new 115017b [improve](catalog) improve code (#222)
115017b is described below
commit 115017b9977dfda4adb2415733de3546b0b5513f
Author: Petrichor <[email protected]>
AuthorDate: Wed Nov 1 10:21:03 2023 +0800
[improve](catalog) improve code (#222)
---
.../java/org/apache/doris/flink/catalog/doris/DorisSystem.java | 9 ++++-----
1 file changed, 4 insertions(+), 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
index 77584d3..7aa314f 100644
---
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.connection.SimpleJdbcConnectionProvider;
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 org.slf4j.LoggerFactory;
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 @@ import static
org.apache.flink.util.Preconditions.checkArgument;
*/
@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);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
