e2e_Cloudsqlpostgresql run-time changes

cloudsufi · May 24, 2023 · f4fa249 · f4fa249
1 parent 109283b
commit f4fa249
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 4 deletions.
diff --git a/...dsql-postgresql-plugin/src/e2e-test/feature/cloudsql-postgresql/sink/RunTimeMacro.feature b/...dsql-postgresql-plugin/src/e2e-test/feature/cloudsql-postgresql/sink/RunTimeMacro.feature
@@ -17,7 +17,7 @@
 @Cloudsqlpostgresql_Sink @Cloudsqlpostgresql_Sink_Required
 Feature: CloudSQL-PostgreSQL sink - Verify data transfer to PostgreSQL sink with macro arguments
 
-  @BQ_SOURCE_TEST @POSTGRESQL_TEST_TABLE
+  @BQ_SOURCE_TEST @CLOUDSQLPOSTGRESQL_TEST_TABLE
   Scenario: To verify data is getting transferred from BigQuery source to CloudSQLPostgreSQL sink using macro arguments in connection section
     Given Open Datafusion Project to configure pipeline
     When Expand Plugin group in the LHS plugins list: "Source"
@@ -76,7 +76,7 @@ Feature: CloudSQL-PostgreSQL sink - Verify data transfer to PostgreSQL sink with
     Then Close the pipeline logs
 #    Then Validate the values of records transferred to target PostGreSQL table is equal to the values from source BigQuery table
 
-  @BQ_SOURCE_TEST @POSTGRESQL_TEST_TABLE
+  @BQ_SOURCE_TEST @CLOUDSQLPOSTGRESQL_TEST_TABLE
   Scenario: To verify data is getting transferred from BigQuery source to CloudSQLPostgreSQL sink using macro arguments in basic section
     Given Open Datafusion Project to configure pipeline
     When Expand Plugin group in the LHS plugins list: "Source"

diff --git a/...-plugin/src/e2e-test/java/io/cdap/plugin/cloudsqlpostgresql/CloudSqlPostgreSqlClient.java b/...-plugin/src/e2e-test/java/io/cdap/plugin/cloudsqlpostgresql/CloudSqlPostgreSqlClient.java
@@ -131,8 +131,6 @@ public static boolean compareResultSetData(ResultSet rsSource, ResultSet rsTarge
     return true;
   }
 
-  //Changes by Surya
-
   public static void createSourceTable(String sourceTable, String schema) throws SQLException, ClassNotFoundException {
     try (Connection connect = getCloudSqlConnection();
          Statement statement = connect.createStatement()) {