Improve dead letter log (#527)

* Improve deadletter log * TE warn to debug
Netflix · Aug 16, 2023 · cafbe81 · cafbe81
1 parent 53b84f1
commit cafbe81
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 3 deletions.
diff --git a/...l-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/DeadLetterActor.java b/...l-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/DeadLetterActor.java
@@ -46,8 +46,11 @@ public Receive createReceive() {
                 .match(DeadLetter.class, msg -> {
                     this.numDeadLetterMsgs.increment();
                     String m = toString(msg.message());
-                    log.error("Dead Letter from {} to {} msg:{}", msg.sender(), msg.recipient(),
-                            m.substring(0, Math.min(250, m.length() - 1)));
+                    log.error("Dead Letter from {} to {} msg type: {} payload: {}",
+                        msg.sender(),
+                        msg.recipient(),
+                        msg.message().getClass().getSimpleName(),
+                        m.substring(0, Math.min(250, m.length() - 1)));
                 })
                 .build();
     }

diff --git a/...l-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClusterActor.java b/...l-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClusterActor.java
@@ -775,7 +775,7 @@ private void onCacheJobArtifactsOnTaskExecutorRequest(CacheJobArtifactsOnTaskExe
             }
         }
         else {
-            log.warn("no valid TE state for CacheJobArtifactsOnTaskExecutorRequest: {}", request);
+            log.debug("no valid TE state for CacheJobArtifactsOnTaskExecutorRequest: {}", request);
         }
     }