diff --git a/.github/workflows/test.yml b/.github/workflows/test.yml index c4b9853..97487bf 100644 --- a/.github/workflows/test.yml +++ b/.github/workflows/test.yml @@ -23,12 +23,12 @@ jobs: - 9000:9000 steps: - name: Checkout repository - uses: actions/checkout@v2 + uses: actions/checkout@v4 with: ref: ${{ github.ref }} - name: Set up JDK 17 - uses: actions/setup-java@v2 + uses: actions/setup-java@v4 with: distribution: 'temurin' java-version: '17' diff --git a/src/main/java/org/apache/flink/connector/databend/catalog/DatabendCatalog.java b/src/main/java/org/apache/flink/connector/databend/catalog/DatabendCatalog.java index 482ae0d..91f725b 100644 --- a/src/main/java/org/apache/flink/connector/databend/catalog/DatabendCatalog.java +++ b/src/main/java/org/apache/flink/connector/databend/catalog/DatabendCatalog.java @@ -86,7 +86,7 @@ public void open() throws CatalogException { configuration.setProperty("password", password); String jdbcUrl = DatabendUtil.getJdbcUrl(baseUrl, getDefaultDatabase()); - connection = DriverManager.getConnection(baseUrl, configuration); + connection = DriverManager.getConnection(jdbcUrl, configuration); LOG.info("Created catalog {}, established connection to {}", getName(), jdbcUrl); } catch (Exception e) { throw new CatalogException(String.format("Opening catalog %s failed.", getName()), e);