better error parsing for open

ryancole · Apr 12, 2017 · bbdbb89 · bbdbb89
1 parent fe59f51
commit bbdbb89
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/src/webhdfs.js b/src/webhdfs.js
@@ -319,6 +319,7 @@ WebHDFSClient.prototype.open = function (path, hdfsoptions, requestoptions, call
 
     // format request args
     var args = _.defaults({
+        json: true,
         uri: this.base_url + path,
         qs: _.defaults({
             op: 'open'
@@ -330,7 +331,10 @@ WebHDFSClient.prototype.open = function (path, hdfsoptions, requestoptions, call
 
         // forward request error
         if (error) return callback(error);
-
+
+        if (typeof body === 'object' && 'RemoteException' in body){
+            return callback(new RemoteException(body));
+        }
         // execute callback
         return callback(null, body);