This is an automated email from the ASF dual-hosted git repository. zirui pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/inlong.git
The following commit(s) were added to refs/heads/master by this push: new 0e4f2a2ac7 [INLONG-9388][Sort] Updated version of embedded-redis in sort-connector-redis (#9389) 0e4f2a2ac7 is described below commit 0e4f2a2ac7f2f67cafc5921aeffecfc37cb38b6c Author: Hao <1780095+hnrai...@users.noreply.github.com> AuthorDate: Tue Dec 5 10:48:16 2023 +0800 [INLONG-9388][Sort] Updated version of embedded-redis in sort-connector-redis (#9389) --- .../sort-flink/sort-flink-v1.13/sort-connectors/redis/pom.xml | 4 ++-- .../src/test/java/org/apache/inlong/sort/redis/RedisTableTest.java | 7 ++++--- pom.xml | 1 + 3 files changed, 7 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 fa6c4e7c2a..1ab7665c57 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>${embedded.redis.version}</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 ec869e3eef..b0d330a3a2 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 org.junit.Test; 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(); } diff --git a/pom.xml b/pom.xml index 0ad2f0209e..06a7a72c9c 100644 --- a/pom.xml +++ b/pom.xml @@ -73,6 +73,7 @@ <dockerfile.maven.version>1.4.13</dockerfile.maven.version> <testcontainers.version>1.17.2</testcontainers.version> <docker.organization>inlong</docker.organization> + <embedded.redis.version>1.1.0</embedded.redis.version> <netty.version>4.1.94.Final</netty.version> <jboss.netty.version>3.10.6.Final</jboss.netty.version>