Bug fixes in HdfsFetcher revealed by HdfsFetcherTest (NPE and hiding …

…the VoldemortSerializationException)
jtraupman-li · Jan 14, 2013 · 3b6c282 · 3b6c282
1 parent f97699b
commit 3b6c282
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/contrib/hadoop-store-builder/src/java/voldemort/store/readonly/fetcher/HdfsFetcher.java b/contrib/hadoop-store-builder/src/java/voldemort/store/readonly/fetcher/HdfsFetcher.java
@@ -149,7 +149,11 @@ public HdfsFetcher(DynamicThrottleLimit dynThrottleLimit,
     }
 
     public File fetch(String sourceFileUrl, String destinationFile) throws IOException {
-        return fetch(sourceFileUrl, destinationFile, this.voldemortConfig.getHadoopConfigPath());
+        String hadoopConfigPath = "";
+        if(this.voldemortConfig != null) {
+            hadoopConfigPath = this.voldemortConfig.getHadoopConfigPath();
+        }
+        return fetch(sourceFileUrl, destinationFile, hadoopConfigPath);
     }
 
     public File fetch(String sourceFileUrl, String destinationFile, String hadoopConfigPath)
@@ -274,7 +278,7 @@ public FileSystem run() throws Exception {
             } else {
                 return null;
             }
-        } catch(Exception e) {
+        } catch(IOException e) {
             logger.error("Error while getting Hadoop filesystem : " + e);
             return null;
         } finally {