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)