π
There is a bug with GCS precondition check, which makes job fail under heavy load with GCS backend: FLINK-38225
As suggested by @Xi Zhang I have made a precondition check in [FLINK-38225] Sets proper precondition to ensure that GCS operations are retryable (also if possible, can somebody assign the ticket to me?)
Also as suggested by @david radley added unit tests for functionality.