flink on yarn 用戶代碼獲取keytab本地文件和principal的方法

 

flink on yarn的情況下配置的keytab文件會根據每次yarn application 分配taskmanager的變化都是不一樣的，在部分場景下用戶代碼也需要獲得keytab文件在yarn上的本地路徑，可以通過以下方式拿到文件地址。

   final Map<String, String> ENV = System.getenv();
   
   final String currDir = ENV.get("PWD");
   
   log.info("Current working/local Directory: {}", currDir);
   
   String keytabPath = null;
   File f = new File(currDir, "krb5.keytab");
   keytabPath = f.getAbsolutePath();
   
   log.info("local keytab path: {}", keytabPath);
   
  

   final String remoteKeytabPrincipal = ENV.get("_KEYTAB_PRINCIPAL");
   
   
   log.info("TM: remote keytab principal obtained {}", remoteKeytabPrincipal);