diff --git a/src/operator/groupBy.ts b/src/operator/groupBy.ts
index 0cad0c11bc..6c3ba4b9f5 100644
--- a/src/operator/groupBy.ts
+++ b/src/operator/groupBy.ts
@@ -240,6 +240,7 @@ class GroupDurationSubscriber<K, T> extends Subscriber<T> {
       group.error(err);
     }
     this.parent.removeGroup(this.key);
+    this.unsubscribe();
   }
 
   protected _complete(): void {
@@ -248,6 +249,7 @@ class GroupDurationSubscriber<K, T> extends Subscriber<T> {
       group.complete();
     }
     this.parent.removeGroup(this.key);
+    this.unsubscribe();
   }
 }