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

["O Phiradet (JIRA)" <ji...@apache.org>]

O Phiradet created BAHIR-145:
--------------------------------

             Summary: 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


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:bash}
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-acc-rakuten
"req_1"
{code}

Best regards,
Phiradet



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