beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ieme...@apache.org
Subject [beam] branch master updated: [BEAM-6125] Update jedis to version 3.0.1
Date Mon, 25 Mar 2019 13:44:06 GMT
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 <iemejia@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;
         }


Mime
View raw message