You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@seatunnel.apache.org by ga...@apache.org on 2023/04/28 05:51:25 UTC
[incubator-seatunnel] branch dev updated: [Improve][E2E] Risk of unreproducible test cases: Some container versions do not have a fixed version number (#4592)
This is an automated email from the ASF dual-hosted git repository.
gaojun2048 pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git
The following commit(s) were added to refs/heads/dev by this push:
new 11395bef9 [Improve][E2E] Risk of unreproducible test cases: Some container versions do not have a fixed version number (#4592)
11395bef9 is described below
commit 11395bef929febde00067ba78f7ee761a0944629
Author: Chengyu Yan <ch...@hotmail.com>
AuthorDate: Fri Apr 28 13:51:20 2023 +0800
[Improve][E2E] Risk of unreproducible test cases: Some container versions do not have a fixed version number (#4592)
---
release-note.md | 1 +
.../apache/seatunnel/e2e/connector/amazondynamodb/AmazondynamodbIT.java | 2 +-
.../apache/seatunnel/connectors/seatunnel/cassandra/CassandraIT.java | 2 +-
.../apache/seatunnel/connectors/seatunnel/clickhouse/ClickhouseIT.java | 2 +-
.../java/org/apache/seatunnel/e2e/connector/kafka/CanalToKafkaIT.java | 2 +-
.../java/org/apache/seatunnel/e2e/connector/v2/mongodb/MongodbIT.java | 2 +-
.../src/test/java/org/apache/seatunnel/e2e/connector/neo4j/Neo4jIT.java | 2 +-
7 files changed, 7 insertions(+), 6 deletions(-)
diff --git a/release-note.md b/release-note.md
index d7bfceb3d..b45ec728d 100644
--- a/release-note.md
+++ b/release-note.md
@@ -88,4 +88,5 @@
## Test
### E2E
- [SqlServer CDC] fix SqlServerCDC IT failure #3807
+- [Container Version] Fix risk of unreproducible test cases #4591
diff --git a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-amazondynamodb-e2e/src/test/java/org/apache/seatunnel/e2e/connector/amazondynamodb/AmazondynamodbIT.java b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-amazondynamodb-e2e/src/test/java/org/apache/seatunnel/e2e/connector/amazondynamodb/AmazondynamodbIT.java
index 6368e4b95..a7a9e3f70 100644
--- a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-amazondynamodb-e2e/src/test/java/org/apache/seatunnel/e2e/connector/amazondynamodb/AmazondynamodbIT.java
+++ b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-amazondynamodb-e2e/src/test/java/org/apache/seatunnel/e2e/connector/amazondynamodb/AmazondynamodbIT.java
@@ -81,7 +81,7 @@ import static org.awaitility.Awaitility.given;
@Slf4j
public class AmazondynamodbIT extends TestSuiteBase implements TestResource {
- private static final String AMAZONDYNAMODB_DOCKER_IMAGE = "amazon/dynamodb-local";
+ private static final String AMAZONDYNAMODB_DOCKER_IMAGE = "amazon/dynamodb-local:1.21.0";
private static final String AMAZONDYNAMODB_CONTAINER_HOST = "dynamodb-host";
private static final int AMAZONDYNAMODB_CONTAINER_PORT = 8000;
private static final String AMAZONDYNAMODB_JOB_CONFIG = "/amazondynamodbIT_source_to_sink.conf";
diff --git a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cassandra-e2e/src/test/java/org/apache/seatunnel/connectors/seatunnel/cassandra/CassandraIT.java b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cassandra-e2e/src/test/java/org/apache/seatunnel/connectors/seatunnel/cassandra/CassandraIT.java
index ad548295b..fcb8408dc 100644
--- a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cassandra-e2e/src/test/java/org/apache/seatunnel/connectors/seatunnel/cassandra/CassandraIT.java
+++ b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cassandra-e2e/src/test/java/org/apache/seatunnel/connectors/seatunnel/cassandra/CassandraIT.java
@@ -86,7 +86,7 @@ import java.util.stream.Stream;
@Slf4j
public class CassandraIT extends TestSuiteBase implements TestResource {
- private static final String CASSANDRA_DOCKER_IMAGE = "cassandra";
+ private static final String CASSANDRA_DOCKER_IMAGE = "cassandra:4.1.1";
private static final String HOST = "cassandra";
private static final Integer PORT = 9042;
private static final String INIT_CASSANDRA_PATH = "/init/cassandra_init.conf";
diff --git a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-clickhouse-e2e/src/test/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/ClickhouseIT.java b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-clickhouse-e2e/src/test/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/ClickhouseIT.java
index 6fd90bed4..abc82a1b2 100644
--- a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-clickhouse-e2e/src/test/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/ClickhouseIT.java
+++ b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-clickhouse-e2e/src/test/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/ClickhouseIT.java
@@ -76,7 +76,7 @@ import java.util.stream.Stream;
public class ClickhouseIT extends TestSuiteBase implements TestResource {
private static final Logger LOG = LoggerFactory.getLogger(ClickhouseIT.class);
- private static final String CLICKHOUSE_DOCKER_IMAGE = "yandex/clickhouse-server:latest";
+ private static final String CLICKHOUSE_DOCKER_IMAGE = "yandex/clickhouse-server:22.1.3.7";
private static final String HOST = "clickhouse";
private static final String DRIVER_CLASS = "com.clickhouse.jdbc.ClickHouseDriver";
private static final String INIT_CLICKHOUSE_PATH = "/init/clickhouse_init.conf";
diff --git a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-kafka-e2e/src/test/java/org/apache/seatunnel/e2e/connector/kafka/CanalToKafkaIT.java b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-kafka-e2e/src/test/java/org/apache/seatunnel/e2e/connector/kafka/CanalToKafkaIT.java
index 059e71c3b..f63381d19 100644
--- a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-kafka-e2e/src/test/java/org/apache/seatunnel/e2e/connector/kafka/CanalToKafkaIT.java
+++ b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-kafka-e2e/src/test/java/org/apache/seatunnel/e2e/connector/kafka/CanalToKafkaIT.java
@@ -84,7 +84,7 @@ public class CanalToKafkaIT extends TestSuiteBase implements TestResource {
// ----------------------------------------------------------------------------
// kafka
- private static final String KAFKA_IMAGE_NAME = "confluentinc/cp-kafka:latest";
+ private static final String KAFKA_IMAGE_NAME = "confluentinc/cp-kafka:7.0.9";
private static final String KAFKA_TOPIC = "test-canal-sink";
diff --git a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/java/org/apache/seatunnel/e2e/connector/v2/mongodb/MongodbIT.java b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/java/org/apache/seatunnel/e2e/connector/v2/mongodb/MongodbIT.java
index 9fe05fe21..80a062e61 100644
--- a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/java/org/apache/seatunnel/e2e/connector/v2/mongodb/MongodbIT.java
+++ b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/java/org/apache/seatunnel/e2e/connector/v2/mongodb/MongodbIT.java
@@ -67,7 +67,7 @@ import static java.net.HttpURLConnection.HTTP_UNAUTHORIZED;
@Slf4j
public class MongodbIT extends TestSuiteBase implements TestResource {
- private static final String MONGODB_IMAGE = "mongo:latest";
+ private static final String MONGODB_IMAGE = "mongo:6.0.5";
private static final String MONGODB_CONTAINER_HOST = "e2e_mongodb";
private static final int MONGODB_PORT = 27017;
private static final String MONGODB_DATABASE = "test_db";
diff --git a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-neo4j-e2e/src/test/java/org/apache/seatunnel/e2e/connector/neo4j/Neo4jIT.java b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-neo4j-e2e/src/test/java/org/apache/seatunnel/e2e/connector/neo4j/Neo4jIT.java
index fc1ca5390..a99d79c46 100644
--- a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-neo4j-e2e/src/test/java/org/apache/seatunnel/e2e/connector/neo4j/Neo4jIT.java
+++ b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-neo4j-e2e/src/test/java/org/apache/seatunnel/e2e/connector/neo4j/Neo4jIT.java
@@ -60,7 +60,7 @@ import static org.neo4j.driver.Values.parameters;
@Slf4j
public class Neo4jIT extends TestSuiteBase implements TestResource {
- private static final String CONTAINER_IMAGE = "neo4j:latest";
+ private static final String CONTAINER_IMAGE = "neo4j:5.6.0";
private static final String CONTAINER_HOST = "neo4j-host";
private static final int HTTP_PORT = 7474;
private static final int BOLT_PORT = 7687;