diff --git a/beat/backend/python/data.py b/beat/backend/python/data.py
index 13adf7a201823705315b3d28cffe0e2ebb694164..b673b4f948bb6c3c90854bd5f1859cc0fa52be56 100644
--- a/beat/backend/python/data.py
+++ b/beat/backend/python/data.py
@@ -968,7 +968,7 @@ class CachedDataSink(DataSink):
                     message = "No data written"
                 else:
                     message = "No enough data written: last written {} vs end {}".format(
-                        self.last_data_index, self.end_index
+                        self.last_written_data_index, self.end_index
                     )
 
                 logger.warning("Removing cache files: {}".format(message))