@Override
    public Connection getConnection() throws SQLException {
        return new FlinkConnection(DriverUri.create(url, properties));
    }
@Test
    public void testDataSource() throws Exception {
        FlinkDataSource dataSource = new FlinkDataSource(getDriverUri().getURL(), new Properties());
        try (Connection connection = dataSource.getConnection()) {
            assertEquals("default_catalog", connection.getCatalog());
            assertEquals("default_database", connection.getSchema());
        }
    }