You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ie...@apache.org on 2019/03/25 13:44:06 UTC
[beam] branch master updated: [BEAM-6125] Update jedis to version
3.0.1
This is an automated email from the ASF dual-hosted git repository.
iemejia pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push:
new f921175 [BEAM-6125] Update jedis to version 3.0.1
new 90452d4 Merge pull request #8129: [BEAM-6125] Update jedis to version 3.0.1
f921175 is described below
commit f921175d42be300a918f3497c07c03cc6971fc2b
Author: Ismaël Mejía <ie...@gmail.com>
AuthorDate: Mon Mar 25 11:29:34 2019 +0100
[BEAM-6125] Update jedis to version 3.0.1
---
sdks/java/io/redis/build.gradle | 2 +-
.../io/redis/src/main/java/org/apache/beam/sdk/io/redis/RedisIO.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/sdks/java/io/redis/build.gradle b/sdks/java/io/redis/build.gradle
index 9f4092b..342abc8 100644
--- a/sdks/java/io/redis/build.gradle
+++ b/sdks/java/io/redis/build.gradle
@@ -25,7 +25,7 @@ ext.summary ="IO to read and write on a Redis keystore."
dependencies {
shadow library.java.vendored_guava_20_0
shadow project(path: ":beam-sdks-java-core", configuration: "shadow")
- shadow "redis.clients:jedis:2.9.0"
+ shadow "redis.clients:jedis:3.0.1"
testCompile project(path: ":beam-runners-direct-java", configuration: "shadow")
testCompile library.java.junit
testCompile library.java.slf4j_jdk14
diff --git a/sdks/java/io/redis/src/main/java/org/apache/beam/sdk/io/redis/RedisIO.java b/sdks/java/io/redis/src/main/java/org/apache/beam/sdk/io/redis/RedisIO.java
index 9cdfc2d..39d1b91 100644
--- a/sdks/java/io/redis/src/main/java/org/apache/beam/sdk/io/redis/RedisIO.java
+++ b/sdks/java/io/redis/src/main/java/org/apache/beam/sdk/io/redis/RedisIO.java
@@ -319,7 +319,7 @@ public class RedisIO {
for (String k : keys) {
processContext.output(k);
}
- cursor = scanResult.getStringCursor();
+ cursor = scanResult.getCursor();
if (cursor.equals(ScanParams.SCAN_POINTER_START)) {
finished = true;
}