From 8c39fa4787e07f4f54b24aaf30e01e251fea9b17 Mon Sep 17 00:00:00 2001
From: Mark Paluch <mpaluch@pivotal.io>
Date: Wed, 12 Oct 2016 14:39:53 +0200
Subject: [PATCH] DATACASS-276 - Polishing.

Truncate table while it contains data to reach a defined state for testing.
---
 .../integration/core/CassandraOperationsIntegrationTests.java    | 1 +
 1 file changed, 1 insertion(+)

diff --git a/spring-data-cassandra/src/test/java/org/springframework/data/cassandra/test/integration/core/CassandraOperationsIntegrationTests.java b/spring-data-cassandra/src/test/java/org/springframework/data/cassandra/test/integration/core/CassandraOperationsIntegrationTests.java
index 963691c27..06e36ee9e 100644
--- a/spring-data-cassandra/src/test/java/org/springframework/data/cassandra/test/integration/core/CassandraOperationsIntegrationTests.java
+++ b/spring-data-cassandra/src/test/java/org/springframework/data/cassandra/test/integration/core/CassandraOperationsIntegrationTests.java
@@ -724,6 +724,7 @@ public class CassandraOperationsIntegrationTests extends AbstractKeyspaceCreatin
 	public void stream() throws InterruptedException {
 
 		while(template.select("SELECT * FROM book", Book.class).size() != 0){
+			template.truncate("book");
 			Thread.sleep(10);
 		}