Moritz Mack created BEAM-13458:
----------------------------------
Summary: Error handling in RedisIO writes
Key: BEAM-13458
URL: https://issues.apache.org/jira/browse/BEAM-13458
Project: Beam
Issue Type: Bug
Components: io-java-redis
Reporter: Moritz Mack
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:
{code:java}
Response<List<Object>> resp = pipeline.exec();
pipeline.close(); // does sync internally
resp.get(); // this may throw
{code}
See discussion here
https://github.com/apache/beam/pull/15858#discussion_r765719311
--
This message was sent by Atlassian Jira
(v8.20.1#820001)