Skip to content

Commit ee8ac0b

Browse files
committed
Add support for ES 9.0
1 parent fd6b1da commit ee8ac0b

File tree

1 file changed

+3
-2
lines changed
  • v2/elasticsearch-common/src/main/java/com/google/cloud/teleport/v2/elasticsearch/utils

1 file changed

+3
-2
lines changed

v2/elasticsearch-common/src/main/java/com/google/cloud/teleport/v2/elasticsearch/utils/ElasticsearchIO.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1666,10 +1666,11 @@ static int getBackendVersion(ConnectionConfiguration connectionConfiguration) {
16661666
|| backendVersion == 5
16671667
|| backendVersion == 6
16681668
|| backendVersion == 7
1669-
|| backendVersion == 8),
1669+
|| backendVersion == 8
1670+
|| backendVersion == 9),
16701671
"The Elasticsearch version to connect to is %s.x. "
16711672
+ "This version of the ElasticsearchIO is only compatible with "
1672-
+ "Elasticsearch v8.x, v7.x, v6.x, v5.x and v2.x",
1673+
+ "Elasticsearch v9.x, v8.x, v7.x, v6.x, v5.x and v2.x",
16731674
backendVersion);
16741675
return backendVersion;
16751676

0 commit comments

Comments
 (0)