You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by bi...@apache.org on 2022/06/09 15:01:19 UTC
[storm] branch master updated: STORM-3805 Changing error to warn for retry update operations (#3422)
This is an automated email from the ASF dual-hosted git repository.
bipinprasad pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/storm.git
The following commit(s) were added to refs/heads/master by this push:
new 33918ad0d STORM-3805 Changing error to warn for retry update operations (#3422)
33918ad0d is described below
commit 33918ad0d38ea74286a8236b065505e7b940ea6c
Author: snikhil5 <ns...@yahoo.com>
AuthorDate: Thu Jun 9 10:01:12 2022 -0500
STORM-3805 Changing error to warn for retry update operations (#3422)
* STORM-3805 Changing error to warn for retry update operations
* STORM-3805 Changing error to warn for retry update operations
Co-authored-by: nsingh1 <ni...@nik.com>
---
.../src/main/java/org/apache/storm/localizer/AsyncLocalizer.java | 8 +-------
1 file changed, 1 insertion(+), 7 deletions(-)
diff --git a/storm-server/src/main/java/org/apache/storm/localizer/AsyncLocalizer.java b/storm-server/src/main/java/org/apache/storm/localizer/AsyncLocalizer.java
index 8e2c94286..cad84f57c 100644
--- a/storm-server/src/main/java/org/apache/storm/localizer/AsyncLocalizer.java
+++ b/storm-server/src/main/java/org/apache/storm/localizer/AsyncLocalizer.java
@@ -335,13 +335,7 @@ public class AsyncLocalizer implements AutoCloseable {
f.get();
} catch (Exception e) {
updateBlobExceptions.mark();
- if (Utils.exceptionCauseIsInstanceOf(TTransportException.class, e)) {
- LOG.error("Network error while updating blobs, will retry again later", e);
- } else if (Utils.exceptionCauseIsInstanceOf(NimbusLeaderNotFoundException.class, e)) {
- LOG.error("Nimbus unavailable to update blobs, will retry again later", e);
- } else {
- LOG.error("Could not update blob, will retry again later", e);
- }
+ LOG.warn("Could not update blob ({}), will retry again later." , e.getClass().getName());
}
}
}