本文整理了Java中org.apache.gobblin.yarn.YarnAppSecurityManager.sendTokenFileUpdatedMessage()方法的一些代码示例，展示了YarnAppSecurityManager.sendTokenFileUpdatedMessage()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。YarnAppSecurityManager.sendTokenFileUpdatedMessage()方法的具体详情如下：
包路径：org.apache.gobblin.yarn.YarnAppSecurityManager
类名称：YarnAppSecurityManager
方法名：sendTokenFileUpdatedMessage

YarnAppSecurityManager.sendTokenFileUpdatedMessage介绍

暂无

代码示例

代码示例来源：origin: apache/incubator-gobblin

/**
 * Renew the existing delegation token.
 */
private synchronized void renewDelegationToken() throws IOException, InterruptedException {
 this.token.renew(this.fs.getConf());
 writeDelegationTokenToFile();
 if (!this.firstLogin) {
  // Send a message to the controller and all the participants if this is not the first login
  sendTokenFileUpdatedMessage(InstanceType.CONTROLLER);
  sendTokenFileUpdatedMessage(InstanceType.PARTICIPANT);
 }
}

代码示例来源：origin: apache/incubator-gobblin

/**
 * Login the user from a given keytab file.
 */
private void loginFromKeytab() throws IOException {
 String keyTabFilePath = this.config.getString(GobblinYarnConfigurationKeys.KEYTAB_FILE_PATH);
 if (Strings.isNullOrEmpty(keyTabFilePath)) {
  throw new IOException("Keytab file path is not defined for Kerberos login");
 }
 if (!new File(keyTabFilePath).exists()) {
  throw new IOException("Keytab file not found at: " + keyTabFilePath);
 }
 String principal = this.config.getString(GobblinYarnConfigurationKeys.KEYTAB_PRINCIPAL_NAME);
 if (Strings.isNullOrEmpty(principal)) {
  principal = this.loginUser.getShortUserName() + "/localhost@LOCALHOST";
 }
 Configuration conf = new Configuration();
 conf.set("hadoop.security.authentication",
   UserGroupInformation.AuthenticationMethod.KERBEROS.toString().toLowerCase());
 UserGroupInformation.setConfiguration(conf);
 UserGroupInformation.loginUserFromKeytab(principal, keyTabFilePath);
 LOGGER.info(String.format("Logged in from keytab file %s using principal %s", keyTabFilePath, principal));
 this.loginUser = UserGroupInformation.getLoginUser();
 getNewDelegationTokenForLoginUser();
 writeDelegationTokenToFile();
 if (!this.firstLogin) {
  // Send a message to the controller and all the participants
  sendTokenFileUpdatedMessage(InstanceType.CONTROLLER);
  sendTokenFileUpdatedMessage(InstanceType.PARTICIPANT);
 }
}

代码示例来源：origin: apache/incubator-gobblin

@Test
public void testSendTokenFileUpdatedMessage() throws Exception {
 Logger log = LoggerFactory.getLogger("testSendTokenFileUpdatedMessage");
 this.yarnAppSecurityManager.sendTokenFileUpdatedMessage(InstanceType.CONTROLLER);
 Assert.assertEquals(this.curatorFramework.checkExists().forPath(
   String.format("/%s/CONTROLLER/MESSAGES", YarnSecurityManagerTest.class.getSimpleName())).getVersion(), 0);
 AssertWithBackoff.create().logger(log).timeoutMs(20000)
  .assertEquals(new GetControllerMessageNumFunc(YarnSecurityManagerTest.class.getSimpleName(),
    this.curatorFramework), 1, "1 controller message queued");
}

代码示例来源：origin: org.apache.gobblin/gobblin-yarn

/**
 * Renew the existing delegation token.
 */
private synchronized void renewDelegationToken() throws IOException, InterruptedException {
 this.token.renew(this.fs.getConf());
 writeDelegationTokenToFile();
 if (!this.firstLogin) {
  // Send a message to the controller and all the participants if this is not the first login
  sendTokenFileUpdatedMessage(InstanceType.CONTROLLER);
  sendTokenFileUpdatedMessage(InstanceType.PARTICIPANT);
 }
}

代码示例来源：origin: org.apache.gobblin/gobblin-yarn

/**
 * Login the user from a given keytab file.
 */
private void loginFromKeytab() throws IOException {
 String keyTabFilePath = this.config.getString(GobblinYarnConfigurationKeys.KEYTAB_FILE_PATH);
 if (Strings.isNullOrEmpty(keyTabFilePath)) {
  throw new IOException("Keytab file path is not defined for Kerberos login");
 }
 if (!new File(keyTabFilePath).exists()) {
  throw new IOException("Keytab file not found at: " + keyTabFilePath);
 }
 String principal = this.config.getString(GobblinYarnConfigurationKeys.KEYTAB_PRINCIPAL_NAME);
 if (Strings.isNullOrEmpty(principal)) {
  principal = this.loginUser.getShortUserName() + "/localhost@LOCALHOST";
 }
 Configuration conf = new Configuration();
 conf.set("hadoop.security.authentication",
   UserGroupInformation.AuthenticationMethod.KERBEROS.toString().toLowerCase());
 UserGroupInformation.setConfiguration(conf);
 UserGroupInformation.loginUserFromKeytab(principal, keyTabFilePath);
 LOGGER.info(String.format("Logged in from keytab file %s using principal %s", keyTabFilePath, principal));
 this.loginUser = UserGroupInformation.getLoginUser();
 getNewDelegationTokenForLoginUser();
 writeDelegationTokenToFile();
 if (!this.firstLogin) {
  // Send a message to the controller and all the participants
  sendTokenFileUpdatedMessage(InstanceType.CONTROLLER);
  sendTokenFileUpdatedMessage(InstanceType.PARTICIPANT);
 }
}