Repository: hadoop Updated Branches: refs/heads/branch-2.8 5bb135092 -> 4c47cb68e
HDFS-11333. Print a user friendly error message when plugins are not found. Contributed by Wei-Chiu Chuang. (cherry picked from commit 859bd159ae554174200334b5eb1d7e8dbef958ad) (cherry picked from commit a8531d5d52fb219c2adb5b6025cfc3fad264e8aa) Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/4c47cb68 Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/4c47cb68 Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/4c47cb68 Branch: refs/heads/branch-2.8 Commit: 4c47cb68e88505d5fdc6830a4789e78a974cb9cf Parents: 5bb1350 Author: Wei-Chiu Chuang <weic...@apache.org> Authored: Wed Feb 15 02:50:35 2017 -0800 Committer: Wei-Chiu Chuang <weic...@apache.org> Committed: Wed Feb 15 03:02:41 2017 -0800 ---------------------------------------------------------------------- .../org/apache/hadoop/hdfs/server/datanode/DataNode.java | 10 +++++++++- .../org/apache/hadoop/hdfs/server/namenode/NameNode.java | 11 +++++++++-- 2 files changed, 18 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/4c47cb68/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/DataNode.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/DataNode.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/DataNode.java index 55e68f0..1ff9617 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/DataNode.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/DataNode.java @@ -913,7 +913,15 @@ public class DataNode extends ReconfigurableBase } private void startPlugins(Configuration conf) { - plugins = conf.getInstances(DFS_DATANODE_PLUGINS_KEY, ServicePlugin.class); + try { + plugins = conf.getInstances(DFS_DATANODE_PLUGINS_KEY, + ServicePlugin.class); + } catch (RuntimeException e) { + String pluginsValue = conf.get(DFS_DATANODE_PLUGINS_KEY); + LOG.error("Unable to load DataNode plugins. Specified list of plugins: " + + pluginsValue, e); + throw e; + } for (ServicePlugin p: plugins) { try { p.start(this); http://git-wip-us.apache.org/repos/asf/hadoop/blob/4c47cb68/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/NameNode.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/NameNode.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/NameNode.java index 9fec319..a44df77 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/NameNode.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/NameNode.java @@ -765,8 +765,15 @@ public class NameNode implements NameNodeStatusMXBean { httpServer.setFSImage(getFSImage()); } rpcServer.start(); - plugins = conf.getInstances(DFS_NAMENODE_PLUGINS_KEY, - ServicePlugin.class); + try { + plugins = conf.getInstances(DFS_NAMENODE_PLUGINS_KEY, + ServicePlugin.class); + } catch (RuntimeException e) { + String pluginsValue = conf.get(DFS_NAMENODE_PLUGINS_KEY); + LOG.error("Unable to load NameNode plugins. Specified list of plugins: " + + pluginsValue, e); + throw e; + } for (ServicePlugin p: plugins) { try { p.start(this); --------------------------------------------------------------------- To unsubscribe, e-mail: common-commits-unsubscr...@hadoop.apache.org For additional commands, e-mail: common-commits-h...@hadoop.apache.org