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)

Reply via email to