You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@bahir.apache.org by rm...@apache.org on 2017/11/26 15:09:54 UTC
bahir-flink git commit: [BAHIR-145] Fix the JedisCluster function
called when performing PFADD
Repository: bahir-flink
Updated Branches:
refs/heads/master 4f0179a17 -> 6a243f3ea
[BAHIR-145] Fix the JedisCluster function called when performing PFADD
This closes #23
Project: http://git-wip-us.apache.org/repos/asf/bahir-flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/bahir-flink/commit/6a243f3e
Tree: http://git-wip-us.apache.org/repos/asf/bahir-flink/tree/6a243f3e
Diff: http://git-wip-us.apache.org/repos/asf/bahir-flink/diff/6a243f3e
Branch: refs/heads/master
Commit: 6a243f3eaed51d958dbde06b50ad9f4db3aee7b6
Parents: 4f0179a
Author: Bang, Phiradet <ph...@rakuten.com>
Authored: Wed Nov 22 13:48:45 2017 +0900
Committer: Robert Metzger <rm...@apache.org>
Committed: Wed Nov 22 10:33:07 2017 +0100
----------------------------------------------------------------------
.../connectors/redis/common/container/RedisClusterContainer.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/bahir-flink/blob/6a243f3e/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/container/RedisClusterContainer.java
----------------------------------------------------------------------
diff --git a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/container/RedisClusterContainer.java b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/container/RedisClusterContainer.java
index ba733f7..8a39f03 100644
--- a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/container/RedisClusterContainer.java
+++ b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/container/RedisClusterContainer.java
@@ -137,7 +137,7 @@ public class RedisClusterContainer implements RedisCommandsContainer, Closeable
@Override
public void pfadd(final String key, final String element) {
try {
- jedisCluster.set(key, element);
+ jedisCluster.pfadd(key, element);
} catch (Exception e) {
if (LOG.isErrorEnabled()) {
LOG.error("Cannot send Redis message with command PFADD to key {} error message {}",