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

YarnShuffleService.isAuthenticationEnabled介绍

[英]Return whether authentication is enabled as specified by the configuration. If so, fetch requests will fail unless the appropriate authentication secret for the application is provided.
[中]返回是否按照配置指定启用了身份验证。如果是这样，除非为应用程序提供适当的身份验证密钥，否则获取请求将失败。

代码示例

代码示例来源：origin: io.snappydata/snappy-spark-network-yarn

@Override
public void initializeApplication(ApplicationInitializationContext context) {
 String appId = context.getApplicationId().toString();
 try {
  ByteBuffer shuffleSecret = context.getApplicationDataForService();
  logger.info("Initializing application {}", appId);
  if (isAuthenticationEnabled()) {
   AppId fullId = new AppId(appId);
   if (db != null) {
    byte[] key = dbAppKey(fullId);
    byte[] value = mapper.writeValueAsString(shuffleSecret).getBytes(StandardCharsets.UTF_8);
    db.put(key, value);
   }
   secretManager.registerApp(appId, shuffleSecret);
  }
 } catch (Exception e) {
  logger.error("Exception when initializing application {}", appId, e);
 }
}

代码示例来源：origin: org.apache.spark/spark-network-yarn_2.10

@Override
public void initializeApplication(ApplicationInitializationContext context) {
 String appId = context.getApplicationId().toString();
 try {
  ByteBuffer shuffleSecret = context.getApplicationDataForService();
  if (isAuthenticationEnabled()) {
   AppId fullId = new AppId(appId);
   if (db != null) {
    byte[] key = dbAppKey(fullId);
    byte[] value = mapper.writeValueAsString(shuffleSecret).getBytes(StandardCharsets.UTF_8);
    db.put(key, value);
   }
   secretManager.registerApp(appId, shuffleSecret);
  }
 } catch (Exception e) {
  logger.error("Exception when initializing application {}", appId, e);
 }
}

代码示例来源：origin: org.apache.spark/spark-network-yarn_2.11

@Override
public void initializeApplication(ApplicationInitializationContext context) {
 String appId = context.getApplicationId().toString();
 try {
  ByteBuffer shuffleSecret = context.getApplicationDataForService();
  if (isAuthenticationEnabled()) {
   AppId fullId = new AppId(appId);
   if (db != null) {
    byte[] key = dbAppKey(fullId);
    byte[] value = mapper.writeValueAsString(shuffleSecret).getBytes(StandardCharsets.UTF_8);
    db.put(key, value);
   }
   secretManager.registerApp(appId, shuffleSecret);
  }
 } catch (Exception e) {
  logger.error("Exception when initializing application {}", appId, e);
 }
}

代码示例来源：origin: io.snappydata/snappy-spark-network-yarn

@Override
public void stopApplication(ApplicationTerminationContext context) {
 String appId = context.getApplicationId().toString();
 try {
  logger.info("Stopping application {}", appId);
  if (isAuthenticationEnabled()) {
   AppId fullId = new AppId(appId);
   if (db != null) {
    try {
     db.delete(dbAppKey(fullId));
    } catch (IOException e) {
     logger.error("Error deleting {} from executor state db", appId, e);
    }
   }
   secretManager.unregisterApp(appId);
  }
  blockHandler.applicationRemoved(appId, false /* clean up local dirs */);
 } catch (Exception e) {
  logger.error("Exception when stopping application {}", appId, e);
 }
}

代码示例来源：origin: org.apache.spark/spark-network-yarn_2.11

@Override
public void stopApplication(ApplicationTerminationContext context) {
 String appId = context.getApplicationId().toString();
 try {
  if (isAuthenticationEnabled()) {
   AppId fullId = new AppId(appId);
   if (db != null) {
    try {
     db.delete(dbAppKey(fullId));
    } catch (IOException e) {
     logger.error("Error deleting {} from executor state db", appId, e);
    }
   }
   secretManager.unregisterApp(appId);
  }
  blockHandler.applicationRemoved(appId, false /* clean up local dirs */);
 } catch (Exception e) {
  logger.error("Exception when stopping application {}", appId, e);
 }
}

代码示例来源：origin: org.apache.spark/spark-network-yarn_2.10

@Override
public void stopApplication(ApplicationTerminationContext context) {
 String appId = context.getApplicationId().toString();
 try {
  if (isAuthenticationEnabled()) {
   AppId fullId = new AppId(appId);
   if (db != null) {
    try {
     db.delete(dbAppKey(fullId));
    } catch (IOException e) {
     logger.error("Error deleting {} from executor state db", appId, e);
    }
   }
   secretManager.unregisterApp(appId);
  }
  blockHandler.applicationRemoved(appId, false /* clean up local dirs */);
 } catch (Exception e) {
  logger.error("Exception when stopping application {}", appId, e);
 }
}