[flink] branch master updated: [FLINK-23004][yarn] Fix misleading log

[li...@apache.org]

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

lirui 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 9785ea4  [FLINK-23004][yarn] Fix misleading log
9785ea4 is described below

commit 9785ea4ee896ae6b11303abc6b62078c37e589cd
Author: junfan.zhang <ju...@outlook.com>
AuthorDate: Wed Jun 16 11:31:28 2021 +0800

    [FLINK-23004][yarn] Fix misleading log
    
    This closes #16169
---
 flink-yarn/src/main/java/org/apache/flink/yarn/Utils.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/flink-yarn/src/main/java/org/apache/flink/yarn/Utils.java b/flink-yarn/src/main/java/org/apache/flink/yarn/Utils.java
index a8c6e83..fd0fd7d 100644
--- a/flink-yarn/src/main/java/org/apache/flink/yarn/Utils.java
+++ b/flink-yarn/src/main/java/org/apache/flink/yarn/Utils.java
@@ -437,7 +437,7 @@ public final class Utils {
         LocalResource keytabResource = null;
         if (remoteKeytabPath != null) {
             log.info(
-                    "Adding keytab {} to the AM container local resource bucket", remoteKeytabPath);
+                    "TM:Adding keytab {} to the container local resource bucket", remoteKeytabPath);
             Path keytabPath = new Path(remoteKeytabPath);
             FileSystem fs = keytabPath.getFileSystem(yarnConfig);
             keytabResource = registerLocalResource(fs, keytabPath, LocalResourceType.FILE);