diff --git a/bootstrap/sql/migrations/native/1.6.0/mysql/schemaChanges.sql b/bootstrap/sql/migrations/native/1.6.0/mysql/schemaChanges.sql
index d5f08a37e949..7f90aff02aef 100644
--- a/bootstrap/sql/migrations/native/1.6.0/mysql/schemaChanges.sql
+++ b/bootstrap/sql/migrations/native/1.6.0/mysql/schemaChanges.sql
@@ -9,7 +9,7 @@ CREATE TABLE IF NOT EXISTS apps_data_store (
 );
 
 -- Add the source column to the consumers_dlq table
-ALTER TABLE consumers_dlq ADD COLUMN source VARCHAR(255) NOT NULL;
+ALTER TABLE consumers_dlq ADD COLUMN source VARCHAR(255);
 
 -- Create an index on the source column in the consumers_dlq table
 CREATE INDEX idx_consumers_dlq_source ON consumers_dlq (source);
\ No newline at end of file
diff --git a/bootstrap/sql/migrations/native/1.6.0/postgres/schemaChanges.sql b/bootstrap/sql/migrations/native/1.6.0/postgres/schemaChanges.sql
index d5f08a37e949..7f90aff02aef 100644
--- a/bootstrap/sql/migrations/native/1.6.0/postgres/schemaChanges.sql
+++ b/bootstrap/sql/migrations/native/1.6.0/postgres/schemaChanges.sql
@@ -9,7 +9,7 @@ CREATE TABLE IF NOT EXISTS apps_data_store (
 );
 
 -- Add the source column to the consumers_dlq table
-ALTER TABLE consumers_dlq ADD COLUMN source VARCHAR(255) NOT NULL;
+ALTER TABLE consumers_dlq ADD COLUMN source VARCHAR(255);
 
 -- Create an index on the source column in the consumers_dlq table
 CREATE INDEX idx_consumers_dlq_source ON consumers_dlq (source);
\ No newline at end of file