diff --git a/tasks/main.yml b/tasks/main.yml
index 216b837..58027bc 100644
--- a/tasks/main.yml
+++ b/tasks/main.yml
@@ -16,6 +16,11 @@
       pause:
         minutes: 1
 
+    - name: Nodetool flush before repair
+      shell: '{{ nodetool }} flush'
+      environment:
+        JAVA_HOME: '{{ java_home }}'
+
     - name: Try again to streaming repair Cassandra nodes
       shell: '{{ nodetool }} repair -pr'
       environment: