bulker: fix

jitsucom · Sep 11, 2024 · ce7cf6f · ce7cf6f
1 parent db3cf3d
commit ce7cf6f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/bulkerlib/implementations/sql/abstract.go b/bulkerlib/implementations/sql/abstract.go
@@ -208,7 +208,7 @@ func (ps *AbstractSQLStream) adjustTableColumnTypes(currentTable, existingTable,
 		if existingCol.DataType == newCol.DataType {
 			continue
 		}
-		if newCol.Override || newCol.Important {
+		if (newCol.Override || newCol.Important) && existingCol.New {
 			//if column sql type is overridden by user - leave it this way
 			current.Set(name, newCol)
 			continue