beam
beam copied to clipboard
Introduce proper retry handling for Python BigTable I/O
Currently we only have a sink and the implementation is here: https://github.com/apache/beam/blob/master/sdks/python/apache_beam/io/gcp/bigtableio.py
For example, we should properly identify various errors codes and retry failed mutations appropriately.
Imported from Jira BEAM-13849. Original Jira may contain additional context. Reported by: chamikara.
I'd like to take this one up if it's a valid issue and is still available.
Not needed any more. Please check the comments in BEAM-13849
.close-issue