SLIDER-574 print log message when no service keytabs are localized
Project: http://git-wip-us.apache.org/repos/asf/incubator-slider/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-slider/commit/e23e680f Tree: http://git-wip-us.apache.org/repos/asf/incubator-slider/tree/e23e680f Diff: http://git-wip-us.apache.org/repos/asf/incubator-slider/diff/e23e680f Branch: refs/heads/feature/SLIDER-531-registry-enhancements Commit: e23e680fe8e329410126ff4a83ad004ce91b528a Parents: 1a071e3 Author: Jon Maron <[email protected]> Authored: Thu Oct 30 21:31:41 2014 -0400 Committer: Jon Maron <[email protected]> Committed: Thu Oct 30 21:31:41 2014 -0400 ---------------------------------------------------------------------- .../apache/slider/providers/agent/AgentProviderService.java | 9 +++++++++ 1 file changed, 9 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-slider/blob/e23e680f/slider-core/src/main/java/org/apache/slider/providers/agent/AgentProviderService.java ---------------------------------------------------------------------- diff --git a/slider-core/src/main/java/org/apache/slider/providers/agent/AgentProviderService.java b/slider-core/src/main/java/org/apache/slider/providers/agent/AgentProviderService.java index 934e5f0..4720ced 100644 --- a/slider-core/src/main/java/org/apache/slider/providers/agent/AgentProviderService.java +++ b/slider-core/src/main/java/org/apache/slider/providers/agent/AgentProviderService.java @@ -521,9 +521,11 @@ public class AgentProviderService extends AbstractProviderService implements getClusterName()); FileStatus[] keytabs = fileSystem.getFileSystem().listStatus(keytabDirPath); LocalResource keytabRes; + boolean serviceKeytabsDeployed = false; for (FileStatus keytab : keytabs) { if (!amKeytabName.equals(keytab.getPath().getName()) && keytab.getPath().getName().endsWith(".keytab")) { + serviceKeytabsDeployed = true; log.info("Localizing keytab {}", keytab.getPath().getName()); keytabRes = fileSystem.createAmResource(keytab.getPath(), LocalResourceType.FILE); @@ -532,6 +534,13 @@ public class AgentProviderService extends AbstractProviderService implements keytabRes); } } + if (!serviceKeytabsDeployed) { + log.warn("No service keytabs for the application have been localized. " + + "If the application requires keytabs for secure operation, " + + "please ensure that the required keytabs have been uploaded " + + "to the folder designated by the property {}: {}", + SliderXmlConfKeys.KEY_HDFS_KEYTAB_DIR, keytabDirPath); + } } }
