[FLINK-3667] change log level for JobNotFound to debug

cfd48a6f · Maximilian Michels · a3aea279 · cfd48a6f
隐藏空白更改
内联并排

Showing with 1 addition and 1 deletion

flink-yarn/src/main/scala/org/apache/flink/yarn/YarnJobManager.scala ...src/main/scala/org/apache/flink/yarn/YarnJobManager.scala +1 -1

未找到文件。
--- a/flink-yarn/src/main/scala/org/apache/flink/yarn/YarnJobManager.scala
+++ b/flink-yarn/src/main/scala/org/apache/flink/yarn/YarnJobManager.scala
@@ -140,7 +140,7 @@ class YarnJobManager(
      )

    case jnf: JobNotFound =>
-      log.warn(s"Job with ID ${jnf.jobID} not found in JobManager")
+      log.debug(s"Job with ID ${jnf.jobID} not found in JobManager")
      if (stopWhenJobFinished == null) {
        log.warn("The ApplicationMaster didn't expect to receive this message")
      }