Uploaded image for project: 'Beam'
  1. Beam
  2. BEAM-13458

Error handling in RedisIO writes

Details

    • Bug
    • Status: Open
    • P2
    • Resolution: Unresolved
    • None
    • None
    • io-java-redis

    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

       

       

      Attachments

        Activity

          People

            Unassigned Unassigned
            mosche Moritz Mack
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated: