lakshmi-manasa-g opened a new pull request #1542: URL: https://github.com/apache/samza/pull/1542
Symptom: interrupted thread stays stuck for a long time when interrupted exception is wrapped in another exception. Cause: retry several times for all exceptions during block upload. though InterruptedException was immediately bubbled up in #1511, when wrapped it is not bubbled. Changes: remove retries at samza level since azure sdk does the retries. Samza uses [BlobServiceClientBuilder](https://github.com/apache/samza/blob/master/samza-azure/src/main/java/org/apache/samza/system/azureblob/AzureBlobClientBuilder.java#L89) which uses [RequestRetryOptions](https://github.com/Azure/azure-sdk-for-java/blob/5d602a2d97d36c1b20fc56863313222897c032ed/sdk/storage/azure-storage-blob/src/main/java/com/azure/storage/blob/BlobServiceClientBuilder.java#L72) as the default retry policy and the [RequestRetryOptions sets max retries to 4 with exponential backoff](https://github.com/Azure/azure-sdk-for-java/blob/3f31d68eed6fbe11516ca3afe3955c8840a6e974/sdk/storage/azure-storage-common/src/main/java/com/azure/storage/common/policy/RequestRetryOptions.java#L97). Tests: removing retry. API changes: None Usage/upgrade instructions: N/A Backwards compatible: yes -- 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]
