diff --git a/frontera/contrib/backends/hbase.py b/frontera/contrib/backends/hbase.py
index ede89e3a1..f88014298 100644
--- a/frontera/contrib/backends/hbase.py
+++ b/frontera/contrib/backends/hbase.py
@@ -297,7 +297,10 @@ def get(obj):
             fprint = obj.meta[b'fingerprint']
             obj.meta[b'state'] = self._state_cache[fprint] if fprint in self._state_cache else States.DEFAULT
         [get(obj) for obj in objs]
-
+        
+    def frontier_stop(self):
+        self.flush(True)
+        
     def flush(self, force_clear):
         if len(self._state_cache) > self._cache_size_limit:
             force_clear = True