[incubator-seatunnel] branch dev updated: [Bug] [Connector-v2-redis] Fix redis e2e-testcase connection reset (#2644)

[tyrantlucifer]

This is an automated email from the ASF dual-hosted git repository.

tyrantlucifer 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 4409425d5 [Bug] [Connector-v2-redis] Fix redis e2e-testcase connection 
reset (#2644)
4409425d5 is described below

commit 4409425d57e4451855d7c0d5eb63be474fb0935c
Author: hailin0 <wanghai...@apache.org>
AuthorDate: Mon Sep 5 13:57:52 2022 +0800

    [Bug] [Connector-v2-redis] Fix redis e2e-testcase connection reset (#2644)
---
 .../src/test/java/org/apache/seatunnel/e2e/flink/v2/redis/RedisIT.java   | 1 +
 .../src/test/java/org/apache/seatunnel/e2e/spark/v2/redis/RedisIT.java   | 1 +
 2 files changed, 2 insertions(+)

diff --git 
a/seatunnel-e2e/seatunnel-flink-connector-v2-e2e/src/test/java/org/apache/seatunnel/e2e/flink/v2/redis/RedisIT.java
 
b/seatunnel-e2e/seatunnel-flink-connector-v2-e2e/src/test/java/org/apache/seatunnel/e2e/flink/v2/redis/RedisIT.java
index 554cf0752..271ba232a 100644
--- 
a/seatunnel-e2e/seatunnel-flink-connector-v2-e2e/src/test/java/org/apache/seatunnel/e2e/flink/v2/redis/RedisIT.java
+++ 
b/seatunnel-e2e/seatunnel-flink-connector-v2-e2e/src/test/java/org/apache/seatunnel/e2e/flink/v2/redis/RedisIT.java
@@ -64,6 +64,7 @@ public class RedisIT extends FlinkContainer {
 
     private void initJedis() {
         jedis = new Jedis(REDIS_HOST, REDIS_PORT);
+        jedis.connect();
     }
 
     private void generateTestData() {
diff --git 
a/seatunnel-e2e/seatunnel-spark-connector-v2-e2e/src/test/java/org/apache/seatunnel/e2e/spark/v2/redis/RedisIT.java
 
b/seatunnel-e2e/seatunnel-spark-connector-v2-e2e/src/test/java/org/apache/seatunnel/e2e/spark/v2/redis/RedisIT.java
index 5fcf05f58..a597be1cc 100644
--- 
a/seatunnel-e2e/seatunnel-spark-connector-v2-e2e/src/test/java/org/apache/seatunnel/e2e/spark/v2/redis/RedisIT.java
+++ 
b/seatunnel-e2e/seatunnel-spark-connector-v2-e2e/src/test/java/org/apache/seatunnel/e2e/spark/v2/redis/RedisIT.java
@@ -64,6 +64,7 @@ public class RedisIT extends SparkContainer {
 
     private void initJedis() {
         jedis = new Jedis(REDIS_HOST, REDIS_PORT);
+        jedis.connect();
     }
 
     private void generateTestData() {