diff --git a/index.js b/index.js
index eb4a41d9ba..18db7b0d0d 100644
--- a/index.js
+++ b/index.js
@@ -916,6 +916,14 @@ 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.connected = false;
     this.ready = false;
     this.closing = true;