[storm] branch master updated: STORM-3805 Changing error to warn for retry update operations (#3422)

[bipinprasad]

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 <nsingh.u...@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 <n...@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());
                 }
             }
         }