Fix tests version pickup

mzitnik · mzitnik · commit 683d65df798b · 2025-10-03T08:18:32.000+03:00
diff --git a/flink-connector-clickhouse-integration/src/test/java/com/clickhouse/flink/integration/FlinkTests.java b/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";
     }

Original file line number	Diff line number	Diff line change
`@@ -41,7 +41,7 @@ private String getRoot() throws Exception {`
`41`	`41`	`}`
`42`	`42`
`43`	`43`	`private String exampleSubFolder(String flinkVersion) {`
`44`		`- if (flinkVersion.equalsIgnoreCase("latest") \|\| flinkVersion.startsWith("2.0"))`
	`44`	`+ if (flinkVersion.equalsIgnoreCase("latest") \|\| flinkVersion.startsWith("2."))`
`45`	`45`	`return "flink-v2";`
`46`	`46`	`return "flink-v1.7";`
`47`	`47`	`}`