[flink] branch master updated: [FLINK-32162] Only log error if an error occurred

[chesnay]

This is an automated email from the ASF dual-hosted git repository.

chesnay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new fadde2a378a [FLINK-32162] Only log error if an error occurred
fadde2a378a is described below

commit fadde2a378aac4293676944dd513291919a481e3
Author: Chesnay Schepler <ches...@apache.org>
AuthorDate: Tue May 23 13:29:06 2023 +0200

    [FLINK-32162] Only log error if an error occurred
---
 .../main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java    | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git 
a/flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java
 
b/flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java
index 3b65d979ac6..09cb126ee0b 100644
--- 
a/flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java
+++ 
b/flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java
@@ -1182,7 +1182,10 @@ public abstract class Dispatcher extends 
FencedRpcEndpoint<DispatcherId>
                         getMainThreadExecutor())
                 .whenComplete(
                         (ack, error) -> {
-                            log.debug("Failed to update requirements for job 
{}.", jobId, error);
+                            if (error != null) {
+                                log.debug(
+                                        "Failed to update requirements for job 
{}.", jobId, error);
+                            }
                             
pendingJobResourceRequirementsUpdates.remove(jobId);
                         });
     }