[FLINK-3667] change log level for JobNotFound to debug
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cfd48a6f Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/cfd48a6f Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/cfd48a6f Branch: refs/heads/master Commit: cfd48a6f510c937080df0918fcb05aa410885c29 Parents: a3aea27 Author: Maximilian Michels <[email protected]> Authored: Fri Jul 1 11:18:55 2016 +0200 Committer: Maximilian Michels <[email protected]> Committed: Fri Jul 1 15:22:31 2016 +0200 ---------------------------------------------------------------------- .../src/main/scala/org/apache/flink/yarn/YarnJobManager.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/cfd48a6f/flink-yarn/src/main/scala/org/apache/flink/yarn/YarnJobManager.scala ---------------------------------------------------------------------- diff --git a/flink-yarn/src/main/scala/org/apache/flink/yarn/YarnJobManager.scala b/flink-yarn/src/main/scala/org/apache/flink/yarn/YarnJobManager.scala index 3df1adc..a2ac029 100644 --- 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") }
