[BEAM-13458] Error handling in RedisIO writes

• Type: Bug
• Status: Open
• Priority: P2
• Resolution: Unresolved
• Component/s: io-java-redis
• Labels: redis
• Assignee: Unassigned
• Reporter: Moritz Mack
• Created: 14/Dec/21 13:52
• Updated: 04/Jun/22 22:47

Description

The writes in RedisIO currently don't check the MULTI response for errors, so issues might remain unnoticed. The typical pattern should be something like:

Response<List<Object>> resp = pipeline.exec();
pipeline.close(); // does sync internally
resp.get(); // this may throw 

See discussion here https://github.com/apache/beam/pull/15858#discussion_r765719311