[flink] branch master updated: [FLINK-32370][runtime] Change log level to debug for AbstractHandler when job has not been initialized or is finished

[libenchao]

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

libenchao 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 4248d05da09 [FLINK-32370][runtime] Change log level to debug for 
AbstractHandler when job has not been initialized or is finished
4248d05da09 is described below

commit 4248d05da092e3e580ac3238ea9af51151609e4f
Author: Shammon FY <zjur...@gmail.com>
AuthorDate: Mon Jun 26 08:35:05 2023 +0800

    [FLINK-32370][runtime] Change log level to debug for AbstractHandler when 
job has not been initialized or is finished
    
    This mostly affects the e2e tests which will check the corresponding log 
file content
    
    Close apache/flink#22838
---
 .../org/apache/flink/runtime/rest/handler/AbstractHandler.java   | 9 ++++++++-
 1 file changed, 8 insertions(+), 1 deletion(-)

diff --git 
a/flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/AbstractHandler.java
 
b/flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/AbstractHandler.java
index b7d5c5bdca9..75bbdf495dc 100644
--- 
a/flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/AbstractHandler.java
+++ 
b/flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/AbstractHandler.java
@@ -19,6 +19,7 @@
 package org.apache.flink.runtime.rest.handler;
 
 import org.apache.flink.api.common.time.Time;
+import 
org.apache.flink.runtime.dispatcher.UnavailableDispatcherOperationException;
 import org.apache.flink.runtime.entrypoint.ClusterEntryPointExceptionUtils;
 import org.apache.flink.runtime.rest.FileUploadHandler;
 import org.apache.flink.runtime.rest.FlinkHttpObjectAggregator;
@@ -54,6 +55,7 @@ import org.slf4j.LoggerFactory;
 import javax.annotation.Nonnull;
 import javax.annotation.Nullable;
 
+import java.io.FileNotFoundException;
 import java.io.IOException;
 import java.io.InputStream;
 import java.util.Arrays;
@@ -266,7 +268,12 @@ public abstract class AbstractHandler<
                     HttpResponseStatus.SERVICE_UNAVAILABLE,
                     responseHeaders);
         } else {
-            log.error("Unhandled exception.", throwable);
+            if (throwable instanceof UnavailableDispatcherOperationException
+                    || throwable instanceof FileNotFoundException) {
+                log.debug("Job is not initialized or is finished: {}", 
throwable.getMessage());
+            } else {
+                log.error("Unhandled exception.", throwable);
+            }
             String stackTrace =
                     String.format(
                             "<Exception on server side:%n%s%nEnd of exception 
on server side>",