diff --git a/fivetran/framework/core/model/connector_schema_config.go b/fivetran/framework/core/model/connector_schema_config.go
index a5b33684..29cf58f3 100644
--- a/fivetran/framework/core/model/connector_schema_config.go
+++ b/fivetran/framework/core/model/connector_schema_config.go
@@ -263,7 +263,7 @@ func (d *ConnectorSchemaResourceModel) getSchemasMap(schemas []interface{}) base
 							columnElements["hashed"] = types.BoolNull()
 						}
 
-						if _, ok := localColumn["is_primary_key"]; ok {
+						if _, ok := localColumn["is_primary_key"]; ok && columnMap["is_primary_key"] != nil {
 							columnElements["is_primary_key"] = types.BoolValue(helpers.StrToBool(columnMap["is_primary_key"].(string)))
 						} else {
 							columnElements["is_primary_key"] = types.BoolNull()