diff --git a/sunbird-cassandra-migration/cassandra-migration/src/main/resources/db/migration/cassandra/sunbird/V1.122_cassandra.cql b/sunbird-cassandra-migration/cassandra-migration/src/main/resources/db/migration/cassandra/sunbird/V1.122_cassandra.cql
index b7c2ff95d..2c7c38f0c 100644
--- a/sunbird-cassandra-migration/cassandra-migration/src/main/resources/db/migration/cassandra/sunbird/V1.122_cassandra.cql
+++ b/sunbird-cassandra-migration/cassandra-migration/src/main/resources/db/migration/cassandra/sunbird/V1.122_cassandra.cql
@@ -1,4 +1,4 @@
-CREATE TABLE sunbird.user_roles(
+CREATE TABLE IF NOT EXISTS sunbird.user_roles(
 	userid text,
 	role text,
 	scope text,
diff --git a/sunbird-cassandra-migration/cassandra-migration/src/main/resources/db/migration/cassandra/sunbird/V1.67_cassandra.cql b/sunbird-cassandra-migration/cassandra-migration/src/main/resources/db/migration/cassandra/sunbird/V1.67_cassandra.cql
index e229b0e7c..e76484d15 100644
--- a/sunbird-cassandra-migration/cassandra-migration/src/main/resources/db/migration/cassandra/sunbird/V1.67_cassandra.cql
+++ b/sunbird-cassandra-migration/cassandra-migration/src/main/resources/db/migration/cassandra/sunbird/V1.67_cassandra.cql
@@ -1,6 +1,6 @@
 ALTER TABLE sunbird.user ADD prevUsedPhone text;
 ALTER TABLE sunbird.user ADD prevUsedEmail text;
-CREATE TABLE sunbird.user_cert (id text,certId text,userId text,store map<text,text>,otherLink text,accessCode text,createdAt timestamp, updatedAt timestamp, PRIMARY KEY (id));
+CREATE TABLE IF NOT EXISTS sunbird.user_cert (id text,certId text,userId text,store map<text,text>,otherLink text,accessCode text,createdAt timestamp, updatedAt timestamp, PRIMARY KEY (id));
 CREATE INDEX inx_usrcert_user_id ON sunbird.user_cert(userId);
 CREATE INDEX inx_usrcert_cert_id ON sunbird.user_cert(certId);
 
diff --git a/sunbird-cassandra-migration/cassandra-migration/src/main/resources/db/migration/cassandra/sunbird_notifications/V1.126_cassandra.cql b/sunbird-cassandra-migration/cassandra-migration/src/main/resources/db/migration/cassandra/sunbird_notifications/V1.126_cassandra.cql
index 035e354ee..cae534ffb 100644
--- a/sunbird-cassandra-migration/cassandra-migration/src/main/resources/db/migration/cassandra/sunbird_notifications/V1.126_cassandra.cql
+++ b/sunbird-cassandra-migration/cassandra-migration/src/main/resources/db/migration/cassandra/sunbird_notifications/V1.126_cassandra.cql
@@ -12,7 +12,7 @@ createdBy text,
 lastUpdatedBy text,
 PRIMARY KEY(templateId));
 
-CREATE TABLE sunbird_notifications.notification_feed (
+CREATE TABLE IF NOT EXISTS sunbird_notifications.notification_feed (
     id text PRIMARY KEY,
     category text,
     createdby text,
diff --git a/sunbird-cassandra-migration/cassandra-migration/src/test/resources/migration/cql/V1__First.cql b/sunbird-cassandra-migration/cassandra-migration/src/test/resources/migration/cql/V1__First.cql
index 0fb9f8416..037fddce0 100644
--- a/sunbird-cassandra-migration/cassandra-migration/src/test/resources/migration/cql/V1__First.cql
+++ b/sunbird-cassandra-migration/cassandra-migration/src/test/resources/migration/cql/V1__First.cql
@@ -1,4 +1,4 @@
-CREATE TABLE test (
+CREATE TABLE IF NOT EXISTS test (
   space text,
   key text,
   value text,
diff --git a/sunbird-cassandra-migration/cassandra-migration/src/test/resources/migration/cql/V2_0__Add_contents_table.cql b/sunbird-cassandra-migration/cassandra-migration/src/test/resources/migration/cql/V2_0__Add_contents_table.cql
index c3f765938..2c08eefa9 100644
--- a/sunbird-cassandra-migration/cassandra-migration/src/test/resources/migration/cql/V2_0__Add_contents_table.cql
+++ b/sunbird-cassandra-migration/cassandra-migration/src/test/resources/migration/cql/V2_0__Add_contents_table.cql
@@ -1,4 +1,4 @@
-CREATE TABLE contents (
+CREATE TABLE IF NOT EXISTS contents (
   id bigint PRIMARY KEY,
   title text,
   message text,
diff --git a/sunbird-cassandra-migration/cassandra-migration/src/test/resources/migration/integ/V1_0_0__First.cql b/sunbird-cassandra-migration/cassandra-migration/src/test/resources/migration/integ/V1_0_0__First.cql
index d6a5db707..93c178271 100644
--- a/sunbird-cassandra-migration/cassandra-migration/src/test/resources/migration/integ/V1_0_0__First.cql
+++ b/sunbird-cassandra-migration/cassandra-migration/src/test/resources/migration/integ/V1_0_0__First.cql
@@ -1,4 +1,4 @@
-CREATE TABLE test1 (
+CREATE TABLE IF NOT EXISTS test1 (
   space text,
   key text,
   value text,
diff --git a/sunbird-cassandra-migration/cassandra-migration/src/test/resources/migration/integ/V2_0_0__Second.cql b/sunbird-cassandra-migration/cassandra-migration/src/test/resources/migration/integ/V2_0_0__Second.cql
index f1e27ad59..8f111db65 100644
--- a/sunbird-cassandra-migration/cassandra-migration/src/test/resources/migration/integ/V2_0_0__Second.cql
+++ b/sunbird-cassandra-migration/cassandra-migration/src/test/resources/migration/integ/V2_0_0__Second.cql
@@ -1,11 +1,11 @@
-CREATE TABLE contents (
+CREATE TABLE IF NOT EXISTS contents (
   id bigint PRIMARY KEY,
   title text,
   message text,
   created timestamp
 );
 
-CREATE TABLE messages (
+CREATE TABLE IF NOT EXISTS messages (
   id bigint PRIMARY KEY,
   contents_id bigint,
   type int,
diff --git a/sunbird-cassandra-migration/cassandra-migration/src/test/resources/migration/integ_outoforder/V1_0_0__First.cql b/sunbird-cassandra-migration/cassandra-migration/src/test/resources/migration/integ_outoforder/V1_0_0__First.cql
index d6a5db707..93c178271 100644
--- a/sunbird-cassandra-migration/cassandra-migration/src/test/resources/migration/integ_outoforder/V1_0_0__First.cql
+++ b/sunbird-cassandra-migration/cassandra-migration/src/test/resources/migration/integ_outoforder/V1_0_0__First.cql
@@ -1,4 +1,4 @@
-CREATE TABLE test1 (
+CREATE TABLE IF NOT EXISTS test1 (
   space text,
   key text,
   value text,
diff --git a/sunbird-cassandra-migration/cassandra-migration/src/test/resources/migration/integ_outoforder/V2_0_0__Second.cql b/sunbird-cassandra-migration/cassandra-migration/src/test/resources/migration/integ_outoforder/V2_0_0__Second.cql
index f1e27ad59..8f111db65 100644
--- a/sunbird-cassandra-migration/cassandra-migration/src/test/resources/migration/integ_outoforder/V2_0_0__Second.cql
+++ b/sunbird-cassandra-migration/cassandra-migration/src/test/resources/migration/integ_outoforder/V2_0_0__Second.cql
@@ -1,11 +1,11 @@
-CREATE TABLE contents (
+CREATE TABLE IF NOT EXISTS contents (
   id bigint PRIMARY KEY,
   title text,
   message text,
   created timestamp
 );
 
-CREATE TABLE messages (
+CREATE TABLE IF NOT EXISTS messages (
   id bigint PRIMARY KEY,
   contents_id bigint,
   type int,
diff --git a/sunbird-cassandra-migration/cassandra-migration/src/test/resources/migration/integ_outoforder2/V1_0_0__First.cql b/sunbird-cassandra-migration/cassandra-migration/src/test/resources/migration/integ_outoforder2/V1_0_0__First.cql
index d6a5db707..93c178271 100644
--- a/sunbird-cassandra-migration/cassandra-migration/src/test/resources/migration/integ_outoforder2/V1_0_0__First.cql
+++ b/sunbird-cassandra-migration/cassandra-migration/src/test/resources/migration/integ_outoforder2/V1_0_0__First.cql
@@ -1,4 +1,4 @@
-CREATE TABLE test1 (
+CREATE TABLE IF NOT EXISTS test1 (
   space text,
   key text,
   value text,
diff --git a/sunbird-cassandra-migration/cassandra-migration/src/test/resources/migration/integ_outoforder2/V2_0_0__Second.cql b/sunbird-cassandra-migration/cassandra-migration/src/test/resources/migration/integ_outoforder2/V2_0_0__Second.cql
index f1e27ad59..8f111db65 100644
--- a/sunbird-cassandra-migration/cassandra-migration/src/test/resources/migration/integ_outoforder2/V2_0_0__Second.cql
+++ b/sunbird-cassandra-migration/cassandra-migration/src/test/resources/migration/integ_outoforder2/V2_0_0__Second.cql
@@ -1,11 +1,11 @@
-CREATE TABLE contents (
+CREATE TABLE IF NOT EXISTS contents (
   id bigint PRIMARY KEY,
   title text,
   message text,
   created timestamp
 );
 
-CREATE TABLE messages (
+CREATE TABLE IF NOT EXISTS messages (
   id bigint PRIMARY KEY,
   contents_id bigint,
   type int,
diff --git a/sunbird-cassandra-migration/cassandra-migration/src/test/resources/migration/integ_outoforder3/V1_0_0__First.cql b/sunbird-cassandra-migration/cassandra-migration/src/test/resources/migration/integ_outoforder3/V1_0_0__First.cql
index d6a5db707..93c178271 100644
--- a/sunbird-cassandra-migration/cassandra-migration/src/test/resources/migration/integ_outoforder3/V1_0_0__First.cql
+++ b/sunbird-cassandra-migration/cassandra-migration/src/test/resources/migration/integ_outoforder3/V1_0_0__First.cql
@@ -1,4 +1,4 @@
-CREATE TABLE test1 (
+CREATE TABLE IF NOT EXISTS test1 (
   space text,
   key text,
   value text,
diff --git a/sunbird-cassandra-migration/cassandra-migration/src/test/resources/migration/integ_outoforder3/V2_0_0__Second.cql b/sunbird-cassandra-migration/cassandra-migration/src/test/resources/migration/integ_outoforder3/V2_0_0__Second.cql
index f1e27ad59..8f111db65 100644
--- a/sunbird-cassandra-migration/cassandra-migration/src/test/resources/migration/integ_outoforder3/V2_0_0__Second.cql
+++ b/sunbird-cassandra-migration/cassandra-migration/src/test/resources/migration/integ_outoforder3/V2_0_0__Second.cql
@@ -1,11 +1,11 @@
-CREATE TABLE contents (
+CREATE TABLE IF NOT EXISTS contents (
   id bigint PRIMARY KEY,
   title text,
   message text,
   created timestamp
 );
 
-CREATE TABLE messages (
+CREATE TABLE IF NOT EXISTS messages (
   id bigint PRIMARY KEY,
   contents_id bigint,
   type int,
diff --git a/sunbird-cassandra-migration/cassandra-migration/src/test/resources/migration/subdir/dir1/V1__First.cql b/sunbird-cassandra-migration/cassandra-migration/src/test/resources/migration/subdir/dir1/V1__First.cql
index 0fb9f8416..037fddce0 100644
--- a/sunbird-cassandra-migration/cassandra-migration/src/test/resources/migration/subdir/dir1/V1__First.cql
+++ b/sunbird-cassandra-migration/cassandra-migration/src/test/resources/migration/subdir/dir1/V1__First.cql
@@ -1,4 +1,4 @@
-CREATE TABLE test (
+CREATE TABLE IF NOT EXISTS test (
   space text,
   key text,
   value text,
diff --git a/sunbird-cassandra-migration/cassandra-migration/src/test/resources/migration/subdir/dir2/V2_0__Add_contents_table.cql b/sunbird-cassandra-migration/cassandra-migration/src/test/resources/migration/subdir/dir2/V2_0__Add_contents_table.cql
index c3f765938..2c08eefa9 100644
--- a/sunbird-cassandra-migration/cassandra-migration/src/test/resources/migration/subdir/dir2/V2_0__Add_contents_table.cql
+++ b/sunbird-cassandra-migration/cassandra-migration/src/test/resources/migration/subdir/dir2/V2_0__Add_contents_table.cql
@@ -1,4 +1,4 @@
-CREATE TABLE contents (
+CREATE TABLE IF NOT EXISTS contents (
   id bigint PRIMARY KEY,
   title text,
   message text,