[ https://issues.apache.org/jira/browse/BAHIR-145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
O Phiradet updated BAHIR-145: ----------------------------- Description: 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-acc-rakuten "req_1" {code} Best regards, Phiradet was: 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 > 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: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-acc-rakuten > "req_1" > {code} > Best regards, > Phiradet -- This message was sent by Atlassian JIRA (v6.4.14#64029)