debug

data-integrations · Nov 27, 2024 · 2299469 · 2299469
1 parent 0126320
commit 2299469
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 4 deletions.
diff --git a/src/e2e-test/java/io/cdap/plugin/bigquery/stepsdesign/BigQueryMultiTable.java b/src/e2e-test/java/io/cdap/plugin/bigquery/stepsdesign/BigQueryMultiTable.java
@@ -48,7 +48,7 @@ public void validateDataTransferredFromBigQueryToBigQueryMultiTableInOneTableIsE
     boolean recordsMatched = BigQueryMultiTableValidation.
       validateBQToBigQueryMultiTable(Collections.singletonList(PluginPropertyUtils.pluginProp("bqSourceTable")),
                                      Collections.singletonList(PluginPropertyUtils.pluginProp
-                                       ("bqmtTargetTableTabB")));
+                                       ("bqTargetTable")));
     Assert.assertTrue("Value of records transferred to the BQ sink should be equal to the value " +
                         "of the records in the source table", recordsMatched);
   }

diff --git a/src/e2e-test/java/io/cdap/plugin/common/stepsdesign/TestSetupHooks.java b/src/e2e-test/java/io/cdap/plugin/common/stepsdesign/TestSetupHooks.java
@@ -1627,7 +1627,6 @@ public static void deleteTargetBqmtTable() throws IOException, InterruptedExcept
       bqTargetTable = PluginPropertyUtils.pluginProp("bqTargetTable");
       BigQueryClient.dropBqQuery(bqTargetTable);
       BeforeActions.scenario.write("BQ Target table - " + bqTargetTable + " deleted successfully");
-      bqTargetTable = StringUtils.EMPTY;
     } catch (BigQueryException e) {
       if (e.getMessage().contains("Not found: Table")) {
         BeforeActions.scenario.write("BQ Target Table " + bqTargetTable + " does not exist");
@@ -1674,8 +1673,6 @@ public static void deleteTwoTargetTables() throws IOException, InterruptedExcept
       BigQueryClient.dropBqQuery(bqTargetTable2);
       BeforeActions.scenario.write("BQ Target table - " + bqTargetTable + " deleted successfully");
       BeforeActions.scenario.write("BQ Target table2 - " + bqTargetTable2 + " deleted successfully");
-      bqTargetTable = StringUtils.EMPTY;
-      bqTargetTable2 = StringUtils.EMPTY;
 
     } catch (BigQueryException e) {
       if (e.getMessage().contains("Not found: Table")) {