From 59aa34d49e385e4771095a7dee21a875af69c767 Mon Sep 17 00:00:00 2001
From: Hao <leo4chin@outlook.com>
Date: Fri, 1 Dec 2023 22:23:01 +0800
Subject: [PATCH] [INLONG-9388][Sort] Updated version of embedded-redis in
 sort-connector-redis

---
 .../sort-flink-v1.13/sort-connectors/redis/pom.xml         | 4 ++--
 .../java/org/apache/inlong/sort/redis/RedisTableTest.java  | 7 ++++---
 2 files changed, 6 insertions(+), 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
index fa6c4e7c2a9..f96a0163cae 100644
--- 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/inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/redis/src/test/java/org/apache/inlong/sort/redis/RedisTableTest.java b/inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/redis/src/test/java/org/apache/inlong/sort/redis/RedisTableTest.java
index ec869e3eefd..b0d330a3a2c 100644
--- a/inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/redis/src/test/java/org/apache/inlong/sort/redis/RedisTableTest.java
+++ b/inlong-sort/sort-flink/sort-flink-v1.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();
         }