Merge pull request #54 from ClickHouse/test-2.1.0

Adding tests coverage for 2.1.0

Author: mzitnik

.github/workflows/integration-tests.yaml

@@ -15,7 +15,7 @@ jobs:
       fail-fast: false
       matrix:
         clickhouse: [ "23.7", "24.3", "latest", "cloud" ]
-        flink: [ "1.17.2", "1.18.1", "1.19.3", "1.20.2", "2.0.0", "latest"]
+        flink: [ "1.17.2", "1.18.1", "1.19.3", "1.20.2", "2.0.0", "2.1.0" , "latest"]
     steps:
       - name: Check for Cloud Credentials
         id: check-cloud-credentials

README.md

@@ -32,6 +32,7 @@ The connector supports two main Apache Flink APIs:
 | Version | Dependency                       | ClickHouse Client Version | Required Java |
 |---------|----------------------------------|---------------------------|---------------|
 | latest  | flink-connector-clickhouse-2.0.0 | 0.9.1                     | Java 17+      |
+| 2.0.1   | flink-connector-clickhouse-2.0.0 | 0.9.1                     | Java 17+      |
 | 2.0.0   | flink-connector-clickhouse-2.0.0 | 0.9.1                     | Java 17+      |
 | 1.20.2  | flink-connector-clickhouse-1.17  | 0.9.1                     | Java 11+      |
 | 1.19.3  | flink-connector-clickhouse-1.17  | 0.9.1                     | Java 11+      |

flink-connector-clickhouse-2.0.0/build.gradle.kts

@@ -1,9 +1,9 @@
 import com.github.jengelman.gradle.plugins.shadow.tasks.ShadowJar
 
 /*
- * Build configuration for Flink 2.0.0 ClickHouse Connector
+ * Build configuration for Flink 2.0.0+ ClickHouse Connector
  *
- * This module provides Apache Flink 2.0.0 compatibility for the ClickHouse connector.
+ * This module provides Apache Flink 2.0.0+ compatibility for the ClickHouse connector.
  * It depends on the flink-connector-clickhouse-base module for shared functionality.
  */
 
@@ -25,7 +25,7 @@ repositories {
 }
 
 extra.apply {
-    set("flinkVersion", "2.0.0")
+    set("flinkVersion", "2.0.0") // the default still will be 2.0.0 since it is more popular currently
     set("log4jVersion","2.17.2")
     set("testContainersVersion", "1.21.0")
     set("byteBuddyVersion", "1.17.5")

flink-connector-clickhouse-integration/src/test/java/com/clickhouse/flink/integration/FlinkTests.java

@@ -41,7 +41,7 @@ private String getRoot() throws Exception {
     }
 
     private String exampleSubFolder(String flinkVersion) {
-        if (flinkVersion.equalsIgnoreCase("latest") || flinkVersion.startsWith("2.0"))
+        if (flinkVersion.equalsIgnoreCase("latest") || flinkVersion.startsWith("2."))
             return "flink-v2";
         return "flink-v1.7";
     }