diff --git a/v2/sourcedb-to-spanner/src/test/resources/DataTypesIT/cassandra-data-types.csql b/v2/sourcedb-to-spanner/src/test/resources/DataTypesIT/cassandra-data-types.csql
index 9116c9e9ad..28ad46c191 100644
--- a/v2/sourcedb-to-spanner/src/test/resources/DataTypesIT/cassandra-data-types.csql
+++ b/v2/sourcedb-to-spanner/src/test/resources/DataTypesIT/cassandra-data-types.csql
@@ -1,5 +1,4 @@
-DROP TABLE IF EXISTS all_data_types;
-CREATE TABLE all_data_types (
+CREATE TABLE IF NOT EXISTS all_data_types (
     primary_key UUID PRIMARY KEY,
     ascii_col ASCII,
     bigint_col BIGINT,
@@ -767,7 +766,7 @@ VALUES (
     {184467440000000000000:BigIntAsBlob(9223372036854775807), -184467440000000000000:BigintAsBlob(-9223372036854775808)} -- varint_blob_map_col
 );
 
-CREATE TABLE "true" (
+CREATE TABLE IF NOT EXISTS "true" (
   "KEY" bigint PRIMARY KEY,
   "CLUSTERING" text
 );
diff --git a/v2/spanner-to-sourcedb/src/test/resources/SpannerCassandraReservedKeywordsIT/cassandra-schema.cql b/v2/spanner-to-sourcedb/src/test/resources/SpannerCassandraReservedKeywordsIT/cassandra-schema.cql
index c1aa6c24a5..9ac6490f8a 100644
--- a/v2/spanner-to-sourcedb/src/test/resources/SpannerCassandraReservedKeywordsIT/cassandra-schema.cql
+++ b/v2/spanner-to-sourcedb/src/test/resources/SpannerCassandraReservedKeywordsIT/cassandra-schema.cql
@@ -1,4 +1,4 @@
-CREATE TABLE "true" (
+CREATE TABLE IF NOT EXISTS "true" (
   "COLUMN" bigint PRIMARY KEY,
   "TABLE" text,
   "WITH" text
diff --git a/v2/spanner-to-sourcedb/src/test/resources/SpannerToCassandraSourceIT/cassandra-schema.sql b/v2/spanner-to-sourcedb/src/test/resources/SpannerToCassandraSourceIT/cassandra-schema.sql
index 7b57c0ae46..3a726867bf 100644
--- a/v2/spanner-to-sourcedb/src/test/resources/SpannerToCassandraSourceIT/cassandra-schema.sql
+++ b/v2/spanner-to-sourcedb/src/test/resources/SpannerToCassandraSourceIT/cassandra-schema.sql
@@ -1,15 +1,15 @@
-CREATE TABLE users (
+CREATE TABLE IF NOT EXISTS users (
     id int PRIMARY KEY,
     full_name text,
     "from" text
 );
 
-CREATE TABLE users2 (
+CREATE TABLE IF NOT EXISTS users2 (
     id int PRIMARY KEY,
     full_name text
 );
 
-CREATE TABLE AllDatatypeTransformation (
+CREATE TABLE IF NOT EXISTS AllDatatypeTransformation (
     varchar_column text PRIMARY KEY,
     tinyint_column tinyint,
     text_column text,
@@ -58,7 +58,7 @@ CREATE TABLE AllDatatypeTransformation (
     bytes_column BLOB
 );
 
-CREATE TABLE AllDatatypeColumns (
+CREATE TABLE IF NOT EXISTS AllDatatypeColumns (
     varchar_column text PRIMARY KEY,
     tinyint_column tinyint,
     text_column text,
@@ -110,7 +110,7 @@ CREATE TABLE AllDatatypeColumns (
 
 );
 
-CREATE TABLE BoundaryConversionTestTable (
+CREATE TABLE IF NOT EXISTS BoundaryConversionTestTable (
     varchar_column text PRIMARY KEY,
     tinyint_column tinyint,
     smallint_column smallint,
@@ -151,7 +151,7 @@ CREATE TABLE BoundaryConversionTestTable (
     map_inet_column map<inet, inet>
 );
 
-CREATE TABLE EmptyStringJsonTable (
+CREATE TABLE IF NOT EXISTS EmptyStringJsonTable (
     varchar_column TEXT PRIMARY KEY,
     empty_column TEXT,
     double_float_map_col MAP<DOUBLE, FLOAT>,
@@ -217,7 +217,7 @@ CREATE TABLE EmptyStringJsonTable (
     frozen_ascii_set_col frozen<SET<ASCII>>
 );
 
-CREATE TABLE testtable_03tpcovf16ed0klxm3v808ch3btgq0uk (
+CREATE TABLE IF NOT EXISTS testtable_03tpcovf16ed0klxm3v808ch3btgq0uk (
     id TEXT PRIMARY KEY,
     col_qcbf69rmxtre3b_03tpcovf16ed TEXT
 );
diff --git a/v2/spanner-to-sourcedb/src/test/resources/SpannerToCassandraSourceIT/cassandra-transformation-schema.sql b/v2/spanner-to-sourcedb/src/test/resources/SpannerToCassandraSourceIT/cassandra-transformation-schema.sql
index 11c74b20f9..c03d9045e9 100644
--- a/v2/spanner-to-sourcedb/src/test/resources/SpannerToCassandraSourceIT/cassandra-transformation-schema.sql
+++ b/v2/spanner-to-sourcedb/src/test/resources/SpannerToCassandraSourceIT/cassandra-transformation-schema.sql
@@ -1,5 +1,4 @@
-DROP TABLE IF EXISTS customers;
-CREATE TABLE customers (
+CREATE TABLE IF NOT EXISTS customers (
     id int PRIMARY KEY,
     full_name text,
     first_name text,
diff --git a/v2/spanner-to-sourcedb/src/test/resources/SpannerToSourceDbWideRowIT/cassandra-10mb-schema.sql b/v2/spanner-to-sourcedb/src/test/resources/SpannerToSourceDbWideRowIT/cassandra-10mb-schema.sql
index 4915e2ca9c..f75c130091 100644
--- a/v2/spanner-to-sourcedb/src/test/resources/SpannerToSourceDbWideRowIT/cassandra-10mb-schema.sql
+++ b/v2/spanner-to-sourcedb/src/test/resources/SpannerToSourceDbWideRowIT/cassandra-10mb-schema.sql
@@ -1,4 +1,4 @@
-CREATE TABLE large_data (
+CREATE TABLE IF NOT EXISTS large_data (
     id UUID PRIMARY KEY,
     large_blob blob
 );
\ No newline at end of file