[jira] [Resolved] (BAHIR-145) Flink Sink for Redis cannot perform PFADD

["Robert Metzger (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/BAHIR-145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Robert Metzger resolved BAHIR-145.
----------------------------------
       Resolution: Fixed
    Fix Version/s: Flink-Next

> Flink Sink for Redis cannot perform PFADD
> -----------------------------------------
>
>                 Key: BAHIR-145
>                 URL: https://issues.apache.org/jira/browse/BAHIR-145
>             Project: Bahir
>          Issue Type: Bug
>          Components: Flink Streaming Connectors
>            Reporter: O Phiradet
>             Fix For: Flink-Next
>
>
> Hi All,
> I have been using the Flink streaming connector for Redis Cluster. I have found the connector cannot perform PFADD command correctly. The root cause is a typo in the method {{pfadd}} of {{org.apache.flink.streaming.connectors.redis.common.container.RedisClusterContainer}}. The method {{pfadd}} of {{jedisCluster}} should be called, not {{set}}. 
> This bug will lead to an error when trying to retrieve value with {{PFCOUNT}} command in redis-cli, but {{GET}} works fine. 
> {code:none}
> redis 127.0.0.1:7000> PFCOUNT hll-key
> (error) WRONGTYPE Key is not a valid HyperLogLog string value.
> redis 127.0.0.1:7000> GET hll-key
> "req_1"
> {code}
> Best regards,
> Phiradet



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)