[BEAM-5714] RedisIO emit error of EXEC without MULTI

• Type: Bug
• Status: Resolved
• Priority: P2
• Resolution: Fixed
• Affects Version/s: 2.7.0
• Fix Version/s: 2.9.0
• Component/s: io-java-redis
• Assignee: Jean-Baptiste Onofré
• Reporter: K.K. POON
• Created: 11/Oct/18 02:58
• Updated: 16/May/20 14:00
• Resolved: 27/Nov/18 14:14

Description

RedisIO has EXEC without MULTI error after SET a batch of records.

 

By looking at the source code, I guess there is missing `pipeline.multi();` after exec() the last batch.

https://github.com/apache/beam/blob/master/sdks/java/io/redis/src/main/java/org/apache/beam/sdk/io/redis/RedisIO.java#L555

Issue Links

• links to: GitHub Pull Request #6651