Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion .github/workflows/integration-tests.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down
1 change: 1 addition & 0 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -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+ |
Expand Down
6 changes: 3 additions & 3 deletions flink-connector-clickhouse-2.0.0/build.gradle.kts
Original file line number Diff line number Diff line change
@@ -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.
*/

Expand All @@ -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")
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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";
}
Expand Down
Loading