[Fix-1672] [cdc] Fix failed to get metadata due to jdbc session timeo…

…ut in CDCSOURCE (DataLinkDC#2471) Co-authored-by: wenmo <[email protected]>
Zzm0809 · Nov 1, 2023 · cbd98dd · cbd98dd
1 parent b75ed15
commit cbd98dd
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 1 deletion.
diff --git a/dinky-executor/src/main/java/org/dinky/trans/ddl/CreateCDCSourceOperation.java b/dinky-executor/src/main/java/org/dinky/trans/ddl/CreateCDCSourceOperation.java
@@ -105,7 +105,7 @@ public TableResult build(Executor executor) {
             final List<String> schemaTableNameList = new ArrayList<>();
             if (SplitUtil.isEnabled(cdcSource.getSplit())) {
                 DriverConfig driverConfig = DriverConfig.build(cdcBuilder.parseMetaDataConfig());
-                Driver driver = Driver.build(driverConfig);
+                Driver driver = Driver.buildNewConnection(driverConfig);
 
                 // 这直接传正则过去
                 schemaTableNameList.addAll(tableRegList.stream()

diff --git a/dinky-metadata/dinky-metadata-base/src/main/java/org/dinky/metadata/driver/Driver.java b/dinky-metadata/dinky-metadata-base/src/main/java/org/dinky/metadata/driver/Driver.java
@@ -70,6 +70,15 @@ static Driver build(DriverConfig config) {
         }
     }
 
+    static Driver buildNewConnection(DriverConfig config) {
+        Optional<Driver> optionalDriver = Driver.get(config);
+        if (!optionalDriver.isPresent()) {
+            throw new MetaDataException("Missing " + config.getType() + " dependency package: dinky-metadata-"
+                    + config.getType().toLowerCase() + ".jar");
+        }
+        return optionalDriver.get().connect();
+    }
+
     static Driver buildUnconnected(DriverConfig config) {
         synchronized (Driver.class) {
             Optional<Driver> optionalDriver = Driver.get(config);