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 <[email protected]> Authored: Wed Nov 22 13:48:45 2017 +0900 Committer: Robert Metzger <[email protected]> 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 {}",
