diff --git a/consumer/cassandra-consumer/src/main/java/org/springframework/cloud/fn/consumer/cassandra/cluster/CassandraAppClusterConfiguration.java b/consumer/cassandra-consumer/src/main/java/org/springframework/cloud/fn/consumer/cassandra/cluster/CassandraAppClusterConfiguration.java
index ab673c50..89b5501a 100644
--- a/consumer/cassandra-consumer/src/main/java/org/springframework/cloud/fn/consumer/cassandra/cluster/CassandraAppClusterConfiguration.java
+++ b/consumer/cassandra-consumer/src/main/java/org/springframework/cloud/fn/consumer/cassandra/cluster/CassandraAppClusterConfiguration.java
@@ -123,7 +123,7 @@ public class CassandraAppClusterConfiguration {
 
 		Flux.fromArray(StringUtils.delimitedListToStringArray(scripts, ";", "\r\n\f"))
 				.filter(StringUtils::hasText) // an empty String after the last ';'
-				.flatMap(script -> reactiveCqlOperations.execute(script + ";"))
+				.concatMap(script -> reactiveCqlOperations.execute(script + ";"))
 				.blockLast();
 
 		return null;