diff --git a/cloudsql-mysql-plugin/src/e2e-test/java/io/cdap/plugin/CloudMySqlClient.java b/cloudsql-mysql-plugin/src/e2e-test/java/io/cdap/plugin/CloudMySqlClient.java index ddcf444cf..bce60717f 100644 --- a/cloudsql-mysql-plugin/src/e2e-test/java/io/cdap/plugin/CloudMySqlClient.java +++ b/cloudsql-mysql-plugin/src/e2e-test/java/io/cdap/plugin/CloudMySqlClient.java @@ -2,7 +2,6 @@ import io.cdap.e2e.utils.PluginPropertyUtils; import org.junit.Assert; - import java.sql.*; import java.util.Date; import java.util.GregorianCalendar; @@ -108,8 +107,6 @@ public static void createSourceTable(String sourceTable) throws SQLException, Cl statement.executeUpdate("INSERT INTO " + sourceTable + " (id, lastName)" + "VALUES (1, 'Priya')"); statement.executeUpdate("INSERT INTO " + sourceTable + " (id, lastName)" + "VALUES (2, 'Shubhangi')"); statement.executeUpdate("INSERT INTO " + sourceTable + " (id, lastName)" + "VALUES (3, 'Shorya')"); - - } } @@ -128,8 +125,6 @@ public static void createSourceDatatypesTable(String sourceTable) throws SQLExce String datatypesColumns = PluginPropertyUtils.pluginProp("datatypesColumns"); String createSourceTableQuery = "CREATE TABLE " + sourceTable + " " + datatypesColumns; statement.executeUpdate(createSourceTableQuery); - System.out.println(createSourceTableQuery); - // Insert dummy data. String datatypesValues = PluginPropertyUtils.pluginProp("datatypesValue1"); String datatypesColumnsList = PluginPropertyUtils.pluginProp("datatypesColumnsList"); @@ -142,7 +137,6 @@ public static void createTargetDatatypesTable(String targetTable) throws SQLExce String datatypesColumns = PluginPropertyUtils.pluginProp("datatypesColumns"); String createTargetTableQuery = "CREATE TABLE " + targetTable + " " + datatypesColumns; statement.executeUpdate(createTargetTableQuery); - System.out.println(createTargetTableQuery); } } @@ -151,11 +145,9 @@ public static void createTargetCloudMysqlTable(String targetTable) throws SQLExc String datatypesColumns = PluginPropertyUtils.pluginProp("CloudMySqlDatatypesColumns"); String createTargetTableQuery = "CREATE TABLE " + targetTable + " " + datatypesColumns; statement.executeUpdate(createTargetTableQuery); - System.out.println(createTargetTableQuery); } } - public static void dropTables(String[] tables) throws SQLException, ClassNotFoundException { try (Connection connect = getCloudSqlConnection(); Statement statement = connect.createStatement()) { for (String table : tables) { diff --git a/cloudsql-mysql-plugin/src/e2e-test/java/io/cdap/plugin/common/stepsdesign/TestSetupHooks.java b/cloudsql-mysql-plugin/src/e2e-test/java/io/cdap/plugin/common/stepsdesign/TestSetupHooks.java index bfce0f509..420044c5f 100644 --- a/cloudsql-mysql-plugin/src/e2e-test/java/io/cdap/plugin/common/stepsdesign/TestSetupHooks.java +++ b/cloudsql-mysql-plugin/src/e2e-test/java/io/cdap/plugin/common/stepsdesign/TestSetupHooks.java @@ -31,8 +31,6 @@ public static void setTableName() { PluginPropertyUtils.addPluginProp("sourceTable", sourceTableName); PluginPropertyUtils.addPluginProp("targetTable", targetTableName); PluginPropertyUtils.addPluginProp("selectQuery", String.format("select * from %s", sourceTableName)); - System.out.println(sourceTableName); - } @Before(order = 1) @@ -147,7 +145,6 @@ private static void createSourceBQTableWithQueries(String bqCreateTableQueryFile // Insert query does not return any record. // Iterator on TableResult values in getSoleQueryResult method throws NoSuchElementException } - System.out.println(bqSourceTable); PluginPropertyUtils.addPluginProp("bqSourceTable", bqSourceTable); BeforeActions.scenario.write("BQ Source Table " + bqSourceTable + " created successfully"); }