[INLONG-9388][Sort] Updated version of embedded-redis in sort-connect…

…or-redis
apache · Dec 1, 2023 · 59aa34d · 59aa34d
1 parent 65f9214
commit 59aa34d
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 5 deletions.
diff --git a/inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/redis/pom.xml b/inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/redis/pom.xml
@@ -73,9 +73,9 @@
             <scope>test</scope>
         </dependency>
         <dependency>
-            <groupId>com.github.kstyrc</groupId>
+            <groupId>com.github.codemonstur</groupId>
             <artifactId>embedded-redis</artifactId>
-            <version>0.6</version>
+            <version>1.1.0</version>
             <scope>test</scope>
         </dependency>
         <dependency>

diff --git a/...1.13/sort-connectors/redis/src/test/java/org/apache/inlong/sort/redis/RedisTableTest.java b/...1.13/sort-connectors/redis/src/test/java/org/apache/inlong/sort/redis/RedisTableTest.java
@@ -29,6 +29,7 @@
 import redis.clients.jedis.Jedis;
 import redis.embedded.RedisServer;
 
+import java.io.IOException;
 import java.util.Arrays;
 import java.util.concurrent.TimeUnit;
 
@@ -45,14 +46,14 @@ public class RedisTableTest {
     private static RedisServer redisServer;
 
     @BeforeClass
-    public static void setup() {
+    public static void setup() throws IOException {
         redisPort = NetUtils.getAvailablePort();
-        redisServer = RedisServer.builder().setting("maxmemory 128m").port(redisPort).build();
+        redisServer = RedisServer.newRedisServer().setting("maxmemory 128m").port(redisPort).build();
         redisServer.start();
     }
 
     @AfterClass
-    public static void cleanup() {
+    public static void cleanup() throws IOException {
         if (redisServer != null) {
             redisServer.stop();
         }