Roberto created BEAM-13284:
------------------------------
Summary: [RedisIO] - Writing with method PFADD doesn't set TTL
Key: BEAM-13284
URL: https://issues.apache.org/jira/browse/BEAM-13284
Project: Beam
Issue Type: Bug
Components: io-java-redis
Reporter: Roberto
RedisIO PFADD writing does not support TTL
if we check the method writeUsingHLLCommand:
[https://github.com/apache/beam/blob/master/sdks/java/io/redis/src/main/java/org/apache/beam/sdk/io/redis/RedisIO.java]
the variable expireTime is not being used
private void writeUsingHLLCommand(KV<String, String> record, Long expireTime) {
String key = record.getKey(); String value = record.getValue();
pipeline.sadd(key, value);
}
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
