diff --git a/user_sync/connector/directory_csv.py b/user_sync/connector/directory_csv.py
index 024053081..773e34414 100644
--- a/user_sync/connector/directory_csv.py
+++ b/user_sync/connector/directory_csv.py
@@ -159,7 +159,7 @@ def get_column_name(key):
 
             country = self.get_column_value(row, country_column_name)
             if country is not None:
-                user['country'] = country
+                user['country'] = country.upper()
 
             groups = self.get_column_value(row, groups_column_name)
             if groups is not None:
diff --git a/user_sync/connector/directory_ldap.py b/user_sync/connector/directory_ldap.py
index c4628aa47..e507e0c98 100755
--- a/user_sync/connector/directory_ldap.py
+++ b/user_sync/connector/directory_ldap.py
@@ -272,7 +272,7 @@ def iter_users(self, users_filter, extended_attributes):
             c_value = LDAPValueFormatter.get_attribute_value(record, six.text_type('c'))
             source_attributes['c'] = c_value
             if c_value is not None:
-                user['country'] = c_value
+                user['country'] = c_value.upper()
 
             if extended_attributes is not None:
                 for extended_attribute in extended_attributes:
diff --git a/user_sync/connector/directory_okta.py b/user_sync/connector/directory_okta.py
index 6bb29d597..53682cacc 100644
--- a/user_sync/connector/directory_okta.py
+++ b/user_sync/connector/directory_okta.py
@@ -227,7 +227,8 @@ def convert_user(self, record, extended_attributes):
             source_attributes['lastName'] = None
 
         if profile.countryCode:
-            source_attributes['countryCode'] = user['country'] = profile.countryCode
+            source_attributes['countryCode'] = profile.countryCode
+            user['country'] = profile.countryCode.upper()
         else:
             source_attributes['countryCode'] = None