diff --git a/.github/workflows/build.yml b/.github/workflows/build.yml
index d58c09d..9825505 100644
--- a/.github/workflows/build.yml
+++ b/.github/workflows/build.yml
@@ -23,14 +23,15 @@ jobs:
runs-on: ubuntu-latest
strategy:
matrix:
- flink: [ "1.17.1" ]
+ flink: [ "1.17.2", "1.18.1", "1.19.0" ]
+ jdk: [ "11" ]
steps:
- uses: actions/checkout@v3
- - name: Set up JDK 11
+ - name: Set up JDK ${{ matrix.jdk }}
uses: actions/setup-java@v3
with:
- java-version: '11'
+ java-version: ${{ matrix.jdk }}
distribution: 'adopt'
cache: maven
diff --git a/CHANGELOG.md b/CHANGELOG.md
index 5895895..ce2955a 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -2,6 +2,8 @@
## [Unreleased]
+- Support Flink 1.19.0.
+
## [0.2.0] - 2024-01-29
- Fix `catalog.include` option and add more logging.
diff --git a/pom.xml b/pom.xml
index 3bb5bb6..1da8d5a 100644
--- a/pom.xml
+++ b/pom.xml
@@ -41,8 +41,8 @@
UTF-8
8.11.1
- 1.17.1
- 3.1.1-1.17
+ 1.18.1
+ 3.1.2-1.18
0.2.0
@@ -176,6 +176,7 @@
com.getindata
flink-connector-jdbc-elasticsearch-dialect
${flink-connector-jdbc-elasticsearch-dialect.version}
+ provided
org.elasticsearch.plugin
diff --git a/src/main/java/com/getindata/flink/connector/jdbc/catalog/IndexFilterResolver.java b/src/main/java/com/getindata/flink/connector/jdbc/catalog/IndexFilterResolver.java
index 06f40c5..8999865 100644
--- a/src/main/java/com/getindata/flink/connector/jdbc/catalog/IndexFilterResolver.java
+++ b/src/main/java/com/getindata/flink/connector/jdbc/catalog/IndexFilterResolver.java
@@ -1,6 +1,5 @@
package com.getindata.flink.connector.jdbc.catalog;
-import org.apache.flink.shaded.guava30.com.google.common.base.Strings;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -24,7 +23,7 @@ static IndexFilterResolver of(String rawIncludePatterns, String rawExcludePatter
}
private static List parseRaw(String commaSeparatedList) {
- if (Strings.isNullOrEmpty(commaSeparatedList)) {
+ if (commaSeparatedList == null || commaSeparatedList.isEmpty()) {
return emptyList();
}
return Arrays.stream(commaSeparatedList.split(","))