diff --git a/index.js b/index.js
index 12e9c7aa2e..8c4d51d59b 100644
--- a/index.js
+++ b/index.js
@@ -909,12 +909,12 @@ RedisClient.prototype.pub_sub_command = function (command_obj) {
 RedisClient.prototype.end = function () {
     this.stream._events = {};
 
+    //clear retry_timer
     if(this.retry_timer){
         clearTimeout(this.retry_timer);
         this.retry_timer=null;
-        this.stream.on("error", function(){
-        });
     }
+    this.stream.on("error", function(){});
 
     this.connected = false;
     this.ready = false;