diff --git a/lib/webhdfs.js b/lib/webhdfs.js
index 70a0252..bd4dd38 100644
--- a/lib/webhdfs.js
+++ b/lib/webhdfs.js
@@ -551,7 +551,7 @@ WebHDFS.prototype.createWriteStream = function createWriteStream (path, append,
   req.on('data', function onError (data) {
     var error = self._parseError(data.toString());
     if (error) {
-      req.end();
+      stream.emit('error', error);
       req.emit('error', error);
     }
   });
diff --git a/package.json b/package.json
index 56ee5f2..7d8bc86 100644
--- a/package.json
+++ b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "webhdfs",
-  "version": "0.1.9",
+  "version": "0.1.10",
   "description": "Node.js WebHDFS REST API client",
   "main": "lib/webhdfs.js",
   "scripts": {