[
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-key
"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: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
> 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-key
> "req_1"
> {code}
> Best regards,
> Phiradet
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
