diff --git a/node-daemon/pvcd/NodeInstance.py b/node-daemon/pvcd/NodeInstance.py
index ce09e025..4f8fa095 100644
--- a/node-daemon/pvcd/NodeInstance.py
+++ b/node-daemon/pvcd/NodeInstance.py
@@ -156,6 +156,7 @@ class NodeInstance(object):
                         while self.flush_stopper:
                             time.sleep(1)
                     self.flush_stopper = False
+                    self.flush_thread = None
                     # Do flushing in a thread so it doesn't block the migrates out
                     if self.domain_state == 'flush':
                         self.flush_thread = threading.Thread(target=self.flush, args=(), kwargs={})