diff --git a/spring-data-cassandra/src/main/java/org/springframework/data/cassandra/repository/query/ReactiveCassandraQueryExecution.java b/spring-data-cassandra/src/main/java/org/springframework/data/cassandra/repository/query/ReactiveCassandraQueryExecution.java
index 782d5fe18..21b23a234 100644
--- a/spring-data-cassandra/src/main/java/org/springframework/data/cassandra/repository/query/ReactiveCassandraQueryExecution.java
+++ b/spring-data-cassandra/src/main/java/org/springframework/data/cassandra/repository/query/ReactiveCassandraQueryExecution.java
@@ -150,6 +150,7 @@ interface ReactiveCassandraQueryExecution {
 
 				if (objects.size() == 1 || limiting) {
 					sink.next(objects.get(0));
+					return;
 				}
 
 				sink.error(new IncorrectResultSizeDataAccessException(1, objects.size()));