diff --git a/data-prepper-plugins/rds-source/src/main/java/org/opensearch/dataprepper/plugins/source/rds/schema/SchemaManager.java b/data-prepper-plugins/rds-source/src/main/java/org/opensearch/dataprepper/plugins/source/rds/schema/SchemaManager.java
index f6aa59d6db..1ed848beee 100644
--- a/data-prepper-plugins/rds-source/src/main/java/org/opensearch/dataprepper/plugins/source/rds/schema/SchemaManager.java
+++ b/data-prepper-plugins/rds-source/src/main/java/org/opensearch/dataprepper/plugins/source/rds/schema/SchemaManager.java
@@ -27,8 +27,7 @@ public class SchemaManager {
     static final String BINLOG_POSITION = "Position";
     static final int NUM_OF_RETRIES = 3;
     static final int BACKOFF_IN_MILLIS = 500;
-    public static final String COLUMN_NAME1 = "COLUMN_NAME";
-    public static final String TYPE_NAME = "TYPE_NAME";
+    static final String TYPE_NAME = "TYPE_NAME";
     private final ConnectionManager connectionManager;
 
     public SchemaManager(ConnectionManager connectionManager) {
@@ -66,7 +65,7 @@ public Map<String, String> getColumnDataTypes(final String database, final Strin
                 try (ResultSet columns = metaData.getColumns(database, null, tableName, null)) {
                     while (columns.next()) {
                         columnsToDataType.put(
-                            columns.getString(COLUMN_NAME1),
+                            columns.getString(COLUMN_NAME),
                             columns.getString(TYPE_NAME)
                         );
                     }