Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with HTTPS or Subversion.

Download ZIP
Browse files

Fixed a jmx unregister bug in hdfs fetcher

  • Loading branch information...
commit 0f2f85eab724f1efd0d704dad29e7c1d53de864a 1 parent e6b24c6
Chinmay Soman authored
View
13 contrib/hadoop-store-builder/src/java/voldemort/store/readonly/fetcher/HdfsFetcher.java
@@ -177,7 +177,15 @@ public FileSystem run() throws Exception {
} catch(InterruptedException e) {
logger.error(e.getMessage());
return null;
+ } catch(Exception e) {
+ logger.error("Got an exception while getting the filesystem object: ");
+ logger.error("Exception class : " + e.getClass());
+ e.printStackTrace();
+ for(StackTraceElement et: e.getStackTrace()) {
+ logger.error(et.toString());
+ }
}
+
} else {
fs = path.getFileSystem(config);
}
@@ -192,7 +200,9 @@ public FileSystem run() throws Exception {
+ " already exists");
}
+ logger.info("Starting fetch for : " + sourceFileUrl);
boolean result = fetch(fs, path, destination, stats);
+ logger.info("Completed fetch : " + sourceFileUrl);
// Close the filesystem
fs.close();
@@ -206,7 +216,8 @@ public FileSystem run() throws Exception {
if(this.globalThrottleLimit != null) {
this.globalThrottleLimit.decrementNumJobs();
}
- JmxUtils.unregisterMbean(jmxName);
+ if(jmxName != null)
+ JmxUtils.unregisterMbean(jmxName);
}
}
Please sign in to comment.
Something went wrong with that request. Please try again.