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 <[email protected]>
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>