debug

data-integrations · Nov 20, 2024 · be2b4c8 · be2b4c8
1 parent e26e7d2
commit be2b4c8
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 6 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
@@ -47,7 +47,8 @@ public void validateDataTransferredFromBigQueryToBigQueryMultiTableInOneTableIsE
     throws IOException, InterruptedException {
     boolean recordsMatched = BigQueryMultiTableValidation.
       validateBQToBigQueryMultiTable(Collections.singletonList(PluginPropertyUtils.pluginProp("bqSourceTable")),
-                                     Collections.singletonList("bqmtTargetTableTabA"));
+                                     Collections.singletonList(PluginPropertyUtils.pluginProp
+                                       ("bqmtTargetTableTabA")));
     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
@@ -1430,7 +1430,7 @@ public static void createTwoSourceBQTable() throws IOException, InterruptedExcep
     try {
       io.cdap.e2e.utils.BigQueryClient.getSoleQueryResult("INSERT INTO `" + datasetName + "." + bqSourceTable2 + "` " +
                                                             "(ID,  tablename, Price, Customer_Exists)" +
-                                                            "VALUES" + "(3, 'tabB', 0.5, true )");
+                                                            "VALUES" + "(3, 'tabsB', 0.5, true )");
     } catch (NoSuchElementException e) {
       // Insert query does not return any record.
       // Iterator on TableResult values in getSoleQueryResult method throws NoSuchElementException
@@ -1442,7 +1442,7 @@ public static void createTwoSourceBQTable() throws IOException, InterruptedExcep
     try {
       io.cdap.e2e.utils.BigQueryClient.getSoleQueryResult("INSERT INTO `" + datasetName + "." + bqSourceTable + "` " +
                                                             "(ID,  tablename, Price, Customer_Exists)" +
-                                                            "VALUES" + "(1, 'tabA', 2.5, true )");
+                                                            "VALUES" + "(1, 'tabsA', 2.5, true )");
     } catch (NoSuchElementException e) {
       // Insert query does not return any record.
       // Iterator on TableResult values in getSoleQueryResult method throws NoSuchElementException

diff --git a/src/e2e-test/resources/pluginParameters.properties b/src/e2e-test/resources/pluginParameters.properties
@@ -1,6 +1,6 @@
 projectId=cdf-athena
 datasetprojectId=cdf-athena
-dataset=testing_bqmt
+dataset=test_bq_sampledataset
 wrongSourcePath=gs://00000000-e2e-0014a44f-81be-4501-8360-0ddca192492
 serviceAccountType=filePath
 serviceAccount=auto-detect
@@ -350,8 +350,8 @@ dsExpectedFile=testdata/BQValidationExpectedFiles/datastoreexpectedfile
 ## BQMT-PLUGIN-PROPERTIES-START
 bqmtCreateTableQueryFile=testdata/BigQuery/BqmtCreateTableQuery.txt
 bqmtInsertDataQueryFile=testdata/BigQuery/BqmtInsertDataQuery.txt
-bqmtTargetTableTabA=tabA
-bqmtTargetTableTabB=tabB
+bqmtTargetTableTabA=tabsA
+bqmtTargetTableTabB=tabsB
 ## BQMT-PLUGIN-PROPERTIES-END
 
 ##CLOUDBIGTABLE-PLUGIN-PROPERTIES-START