hejianchao created FLINK-16548: ---------------------------------- Summary: [Requirement] Consistent id to identify jm/tm in different cluster modes Key: FLINK-16548 URL: https://issues.apache.org/jira/browse/FLINK-16548 Project: Flink Issue Type: Wish Components: Runtime / Configuration Reporter: hejianchao
Imagine that there is now s3-log-appender.jar, and logs can be written to s3 with proper configuration. Then, in the same flink job, the exact same log4j configuration is used. How to make the key written to s3 for different jm / tm carry the id that uniquely identifies jm / tm? such as: s3://bucket/flink-logs/jobId/${jm-id}/logfile s3://bucket/flink-logs/jobId/${tm-1-id}/logfile s3://bucket/flink-logs/jobId/${tm-2-id}/logfile For the s3-log-appender here, it needs a way to sense the value of ${jm-id}/${tm-1-id}/${tm-2-id}, and it has the following claims : 1. This value can be used to locate the actual running jm, tm 2. The value is independent of cluster mode, whether standalone, yarn or kubernetes -- This message was sent by Atlassian Jira (v8.3.4#803005)