debug

data-integrations · Nov 27, 2024 · 879765b · 879765b
1 parent d6c1956
commit 879765b
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 8 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
@@ -36,8 +36,8 @@ public void validateDataTransferredFromBigQueryToBigQueryMultiTableIsEqual()
     List<String> sourceTables = Arrays.asList(PluginPropertyUtils.pluginProp("bqSourceTable"),
                                         PluginPropertyUtils.pluginProp("bqSourceTable2"));
 
-    List<String> targetTables = Arrays.asList(PluginPropertyUtils.pluginProp("bqTargetTable"),
-                                        PluginPropertyUtils.pluginProp("bqTargetTable2"));
+    List<String> targetTables = Arrays.asList(PluginPropertyUtils.pluginProp("bqmtTargetTable"),
+                                        PluginPropertyUtils.pluginProp("bqmtTargetTable2"));
     boolean recordsMatched = BigQueryMultiTableValidation.validateBQToBigQueryMultiTable(sourceTables, targetTables);
     Assert.assertTrue("Value of records transferred to the BQ sink should be equal to the value " +
                         "of the records in the source table", recordsMatched);
@@ -49,7 +49,7 @@ public void validateDataTransferredFromBigQueryToBigQueryMultiTableInOneTableIsE
     boolean recordsMatched = BigQueryMultiTableValidation.
       validateBQToBigQueryMultiTable(Collections.singletonList(TestSetupHooks.bqSourceTable),
                                      Collections.singletonList(PluginPropertyUtils.pluginProp
-                                       ("bqTargetTable")));
+                                       ("bqmtTargetTable")));
     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
@@ -1623,7 +1623,7 @@ public static void createSourceTables() throws IOException, InterruptedException
   @After(order = 2, value = "@BQ_SINK_BQMT_TEST")
   public static void deleteTargetBqmtTable() throws IOException, InterruptedException {
     try {
-      bqTargetTable = PluginPropertyUtils.pluginProp("bqTargetTable");
+      bqTargetTable = PluginPropertyUtils.pluginProp("bqmtTargetTable");
       BigQueryClient.dropBqQuery(bqTargetTable);
       BeforeActions.scenario.write("BQ Target table - " + bqTargetTable + " deleted successfully");
     } catch (BigQueryException e) {
@@ -1666,8 +1666,8 @@ public static void deleteTwoSourceTables() throws IOException, InterruptedExcept
   @After(order = 2, value = "@BQ_TWO_SINK_BQMT_TEST")
   public static void deleteTwoTargetTables() throws IOException, InterruptedException {
     try {
-      bqTargetTable =  PluginPropertyUtils.pluginProp("bqTargetTable");
-      bqTargetTable2 =  PluginPropertyUtils.pluginProp("bqTargetTable2");
+      bqTargetTable =  PluginPropertyUtils.pluginProp("bqmtTargetTable");
+      bqTargetTable2 =  PluginPropertyUtils.pluginProp("bqmtTargetTable2");
       BigQueryClient.dropBqQuery(bqTargetTable);
       BigQueryClient.dropBqQuery(bqTargetTable2);
       BeforeActions.scenario.write("BQ Target table - " + bqTargetTable + " deleted successfully");

diff --git a/src/e2e-test/resources/pluginParameters.properties b/src/e2e-test/resources/pluginParameters.properties
@@ -350,8 +350,10 @@ dsExpectedFile=testdata/BQValidationExpectedFiles/datastoreexpectedfile
 ## BQMT-PLUGIN-PROPERTIES-START
 bqmtCreateTableQueryFile=testdata/BigQuery/BqmtCreateTableQuery.txt
 bqmtInsertDataQueryFile=testdata/BigQuery/BqmtInsertDataQuery.txt
-bqTargetTable=tabA
-bqTargetTable2=tabB
+bqTargetTable=dummy
+bqTargetTable2=dummy
+bqmtTargetTable=tabA
+bqmtTargetTable2=tabB
 ## BQMT-PLUGIN-PROPERTIES-END
 
 ##CLOUDBIGTABLE-PLUGIN-PROPERTIES-START