SQOOP-851: NullPointerException in Mapreduce Submission engine initialization
(Jarcec Cecho via Cheolsoo Park) Project: http://git-wip-us.apache.org/repos/asf/sqoop/repo Commit: http://git-wip-us.apache.org/repos/asf/sqoop/commit/199b06c9 Tree: http://git-wip-us.apache.org/repos/asf/sqoop/tree/199b06c9 Diff: http://git-wip-us.apache.org/repos/asf/sqoop/diff/199b06c9 Branch: refs/heads/sqoop2 Commit: 199b06c98654fbe8b8481afbcd623272f584ac61 Parents: d5dc3a2 Author: Cheolsoo Park <[email protected]> Authored: Thu Jan 31 09:43:23 2013 -0800 Committer: Cheolsoo Park <[email protected]> Committed: Thu Jan 31 09:47:56 2013 -0800 ---------------------------------------------------------------------- .../mapreduce/MapreduceSubmissionEngine.java | 5 +++++ 1 files changed, 5 insertions(+), 0 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/sqoop/blob/199b06c9/submission/mapreduce/src/main/java/org/apache/sqoop/submission/mapreduce/MapreduceSubmissionEngine.java ---------------------------------------------------------------------- diff --git a/submission/mapreduce/src/main/java/org/apache/sqoop/submission/mapreduce/MapreduceSubmissionEngine.java b/submission/mapreduce/src/main/java/org/apache/sqoop/submission/mapreduce/MapreduceSubmissionEngine.java index bcd8124..77f30ea 100644 --- a/submission/mapreduce/src/main/java/org/apache/sqoop/submission/mapreduce/MapreduceSubmissionEngine.java +++ b/submission/mapreduce/src/main/java/org/apache/sqoop/submission/mapreduce/MapreduceSubmissionEngine.java @@ -91,6 +91,11 @@ public class MapreduceSubmissionEngine extends SubmissionEngine { } }); + if(files == null) { + throw new SqoopException(MapreduceSubmissionError.MAPREDUCE_0002, + "Invalid Hadoop configuration directory (not a directory or permission issues): " + configDirectory); + } + // Add each such file to our global configuration object for (String file : files) { LOG.info("Found hadoop configuration file " + file);
