sqoop-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From cheol...@apache.org
Subject [2/3] git commit: SQOOP-851: NullPointerException in Mapreduce Submission engine initialization
Date Thu, 31 Jan 2013 17:48:19 GMT
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 <cheolsoo@apache.org>
Authored: Thu Jan 31 09:43:23 2013 -0800
Committer: Cheolsoo Park <cheolsoo@apache.org>
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);


Mime
View raw message