diff --git a/plugins/destination/plugin.go b/plugins/destination/plugin.go
index 5c3c0995d4..edab723035 100644
--- a/plugins/destination/plugin.go
+++ b/plugins/destination/plugin.go
@@ -297,7 +297,6 @@ func setCqIDNotNullColumnForTables(tables []*schema.Table) {
 		for i, c := range table.Columns {
 			if c.Name == schema.CqIDColumn.Name {
 				table.Columns[i].CreationOptions.NotNull = true
-				return
 			}
 		}
 		setCqIDNotNullColumnForTables(table.Relations)