[FLINK-24088][streaming] Log FlinkJobNotFoundException in debug inste…

…ad of warn level in CollectResultFetcher for a cleaner log This closes apache#17093
ruslandanilin · Sep 6, 2021 · 327a98f · 327a98f
1 parent 73bb9d3
commit 327a98f
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/.../src/main/java/org/apache/flink/streaming/api/operators/collect/CollectResultFetcher.java b/.../src/main/java/org/apache/flink/streaming/api/operators/collect/CollectResultFetcher.java
@@ -26,6 +26,7 @@
 import org.apache.flink.core.execution.JobClient;
 import org.apache.flink.runtime.dispatcher.UnavailableDispatcherOperationException;
 import org.apache.flink.runtime.jobgraph.OperatorID;
+import org.apache.flink.runtime.messages.FlinkJobNotFoundException;
 import org.apache.flink.runtime.operators.coordination.CoordinationRequestGateway;
 import org.apache.flink.util.ExceptionUtils;
 import org.apache.flink.util.Preconditions;
@@ -130,7 +131,13 @@ public T next() throws IOException {
                     if (ExceptionUtils.findThrowable(
                                     e, UnavailableDispatcherOperationException.class)
                             .isPresent()) {
-                        LOG.debug("The job execution has not started yet; cannot fetch results.");
+                        LOG.debug(
+                                "The job execution has not started yet; cannot fetch results.", e);
+                    } else if (ExceptionUtils.findThrowable(e, FlinkJobNotFoundException.class)
+                            .isPresent()) {
+                        LOG.debug(
+                                "The job cannot be found. It is very likely that the job is not in a RUNNING state.",
+                                e);
                     } else {
                         LOG.warn("An exception occurred when fetching query results", e);
                     }