ahmedabu98 opened a new pull request, #28264: URL: https://github.com/apache/beam/pull/28264
Adding a streaming load test for writing via Storage API sink. Includes exactly-one and at-least-once semantics. Also including a small addition for testing purposes: we can set an interval for the sink to intentionally crash every now and then. This is intended to test retry resilience. The sink will sometimes throw an exception to simulate a work item failure, and other times will exit the system to simulate a worker failure. Either way, we expect the pipeline to pick up where it left off and deliver data appropriately. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
