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 index 254f21c3b..f1c49f442 100644 --- 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 index 795ad9cb9..aefc2c0d2 100644 --- 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")) {