[BEAM-13284] [RedisIO] - Writing with method PFADD doesn't set TTL

• Type: Bug
• Status: Resolved
• Priority: P2
• Resolution: Fixed
• Fix Version/s: Missing
• Component/s: io-java-redis
• Assignee: Robert Bradshaw
• Reporter: Roberto
• Created: 18/Nov/21 15:41
• Updated: 13/Jan/22 21:48
• Resolved: 11/Jan/22 17:36

Description

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.pfadd(key, value);
  } 

 

Issue Links

• links to: GitHub Pull Request #16052