[Fix][e2e] Fix flaky Redis tests (#10024)

Author: dybyte

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 void testRedisClusterScan(TestContainer container)
                     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 void testRedisClusterCustomValueWithListType(TestContainer container)
                     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");
         }

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
   }
 }