(seatunnel) branch dev updated: [Fix][e2e] Fix flaky Redis tests (#10024)

[lidongdai]

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

lidongdai pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new 523829237a [Fix][e2e] Fix flaky Redis tests (#10024)
523829237a is described below

commit 523829237a7adf55e64fe785d7c8fe0c0989cdb0
Author: dy102 <132787602+dyb...@users.noreply.github.com>
AuthorDate: Thu Nov 6 23:43:16 2025 +0900

    [Fix][e2e] Fix flaky Redis tests (#10024)
---
 .../seatunnel/e2e/connector/redis/RedisClusterIT.java      | 14 ++++++++------
 .../src/test/resources/cluster-redis-to-redis-scan.conf    |  4 ++--
 2 files changed, 10 insertions(+), 8 deletions(-)

diff --git 
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-redis-e2e/src/test/java/org/apache/seatunnel/e2e/connector/redis/RedisClusterIT.java
 
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-redis-e2e/src/test/java/org/apache/seatunnel/e2e/connector/redis/RedisClusterIT.java
index f57214ae0c..b762ad60dc 100644
--- 
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-redis-e2e/src/test/java/org/apache/seatunnel/e2e/connector/redis/RedisClusterIT.java
+++ 
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-redis-e2e/src/test/java/org/apache/seatunnel/e2e/connector/redis/RedisClusterIT.java
@@ -290,11 +290,11 @@ public class RedisClusterIT extends TestSuiteBase 
implements TestResource {
                     container.executeJob("/cluster-redis-to-redis-scan.conf");
             Assertions.assertEquals(0, execResult.getExitCode());
 
-            long listLength = jedisCluster.llen("key_list");
-            Assertions.assertEquals(100, listLength);
+            long amount = jedisCluster.scard("key_set");
+            Assertions.assertEquals(100, amount);
         } finally {
-            jedisCluster.del("key_list");
-            Assertions.assertEquals(0, jedisCluster.llen("key_list"));
+            jedisCluster.del("key_set");
+            Assertions.assertEquals(0, jedisCluster.llen("key_set"));
         }
     }
 
@@ -345,8 +345,10 @@ public class RedisClusterIT extends TestSuiteBase 
implements TestResource {
                     
container.executeJob("/cluster-redis-to-redis-type-list.conf");
             Assertions.assertEquals(0, execResult.getExitCode());
 
-            long amount = jedisCluster.llen("cluster-list-value-check");
-            Assertions.assertEquals(100, amount);
+            List<String> items = 
jedisCluster.lrange("cluster-list-value-check", 0, -1);
+            Set<String> unique = new HashSet<>(items);
+
+            Assertions.assertEquals(100, unique.size());
         } finally {
             jedisCluster.del("cluster-list-value-check");
         }
diff --git 
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-redis-e2e/src/test/resources/cluster-redis-to-redis-scan.conf
 
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-redis-e2e/src/test/resources/cluster-redis-to-redis-scan.conf
index 71bdf85b9f..583fe794b9 100644
--- 
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-redis-e2e/src/test/resources/cluster-redis-to-redis-scan.conf
+++ 
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-redis-e2e/src/test/resources/cluster-redis-to-redis-scan.conf
@@ -36,8 +36,8 @@ sink {
     nodes = ["redis-cluster-0:6379", "redis-cluster-1:6379", 
"redis-cluster-2:6379"]
     mode = "CLUSTER"
     auth = "SeaTunnel"
-    key = "key_list"
-    data_type = list
+    key = "key_set"
+    data_type = set
     batch_size = 33
   }
 }
\ No newline at end of file