Remove test code

Signed-off-by: Hai Yan <[email protected]>
opensearch-project · Jan 6, 2025 · 9e70372 · 9e70372
1 parent 4fbdbdb
commit 9e70372
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 15 deletions.
diff --git a/...ns/rds-source/src/main/java/org/opensearch/dataprepper/plugins/source/rds/RdsService.java b/...ns/rds-source/src/main/java/org/opensearch/dataprepper/plugins/source/rds/RdsService.java
@@ -181,17 +181,17 @@ private SchemaManager getSchemaManager(final RdsSourceConfig sourceConfig, final
         // For MySQL
         if (sourceConfig.getEngine() == EngineType.MYSQL) {
             final MySqlConnectionManager connectionManager = new MySqlConnectionManager(
-                    "127.0.0.1",
-                    5432,
+                    dbMetadata.getEndpoint(),
+                    dbMetadata.getPort(),
                     sourceConfig.getAuthenticationConfig().getUsername(),
                     sourceConfig.getAuthenticationConfig().getPassword(),
                     sourceConfig.isTlsEnabled());
             return new MySqlSchemaManager(connectionManager);
         }
         // For Postgres
         final PostgresConnectionManager connectionManager = new PostgresConnectionManager(
-                "127.0.0.1",
-                5432,
+                dbMetadata.getEndpoint(),
+                dbMetadata.getPort(),
                 sourceConfig.getAuthenticationConfig().getUsername(),
                 sourceConfig.getAuthenticationConfig().getPassword(),
                 sourceConfig.isTlsEnabled(),
@@ -207,8 +207,8 @@ private QueryManager getQueryManager(final RdsSourceConfig sourceConfig, final D
         final String readerEndpoint = dbMetadata.getReaderEndpoint() != null ? dbMetadata.getReaderEndpoint() : dbMetadata.getEndpoint();
         final int readerPort = dbMetadata.getReaderPort() == 0 ? dbMetadata.getPort() : dbMetadata.getReaderPort();
         final MySqlConnectionManager readerConnectionManager = new MySqlConnectionManager(
-                "127.0.0.1",
-                5432,
+                readerEndpoint,
+                readerPort,
                 sourceConfig.getAuthenticationConfig().getUsername(),
                 sourceConfig.getAuthenticationConfig().getPassword(),
                 sourceConfig.isTlsEnabled());

diff --git a/shared-config/log4j2.properties b/shared-config/log4j2.properties
@@ -31,12 +31,3 @@ logger.plugins.level = info
 
 logger.springframework.name = org.springframework
 logger.springframework.level = info
-
-logger.rds.name = org.opensearch.dataprepper.plugins.source.rds
-logger.rds.level = debug
-
-logger.s3source.name = org.opensearch.dataprepper.plugins.source.s3
-logger.s3source.level = warn
-
-logger.sourcecoord.name = org.opensearch.dataprepper.core.sourcecoordination.LeaseBasedSourceCoordinator
-logger.sourcecoord.level = warn