You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by rm...@apache.org on 2020/03/11 16:40:22 UTC
[flink] branch master updated: [FLINK-16546][yarn] Fix logging bug
in YarnClusterDescriptor#startAppMaster
This is an automated email from the ASF dual-hosted git repository.
rmetzger 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 81c48e5 [FLINK-16546][yarn] Fix logging bug in YarnClusterDescriptor#startAppMaster
81c48e5 is described below
commit 81c48e51248239e8b57655616ebb061b4edb846a
Author: felixzheng <fe...@tencent.com>
AuthorDate: Wed Mar 11 21:01:02 2020 +0800
[FLINK-16546][yarn] Fix logging bug in YarnClusterDescriptor#startAppMaster
---
.../src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java b/flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java
index 553da43..b0c7330 100644
--- a/flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java
+++ b/flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java
@@ -851,7 +851,7 @@ public class YarnClusterDescriptor implements ClusterDescriptor<ApplicationId> {
throw e;
} finally {
if (tmpJobGraphFile != null && !tmpJobGraphFile.delete()) {
- LOG.warn("Fail to delete temporary file {}.", tmpConfigurationFile.toPath());
+ LOG.warn("Fail to delete temporary file {}.", tmpJobGraphFile.toPath());
}
}
}