debug

data-integrations · Nov 28, 2024 · 1666b6b · 1666b6b
1 parent 879765b
commit 1666b6b
Showing 1 changed file with 4 additions and 4 deletions.
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
@@ -1556,8 +1556,8 @@ public static void emptyExistingBigTableInstanceAndTableName() {
 
   @Before(order = 2, value = "@BQ_EXISTING_TARGET_TEST")
   public static void createSinkTables() throws IOException, InterruptedException {
-    bqTargetTable = PluginPropertyUtils.pluginProp("bqTargetTable");
-    bqTargetTable2 = PluginPropertyUtils.pluginProp("bqTargetTable2");
+    bqTargetTable = PluginPropertyUtils.pluginProp("bqmtTargetTable");
+    bqTargetTable2 = PluginPropertyUtils.pluginProp("bqmtTargetTable2");
     io.cdap.e2e.utils.BigQueryClient.getSoleQueryResult("create table `" + datasetName + "." + bqTargetTable + "` " +
                                                           "(ID INT64, tablename STRING," +
                                                           "Price FLOAT64, Customer_Exists BOOL ) ");
@@ -1566,8 +1566,8 @@ public static void createSinkTables() throws IOException, InterruptedException {
                                                           "(ID INT64, tablename STRING," +
                                                           "Price FLOAT64, Customer_Exists BOOL ) ");
 
-    PluginPropertyUtils.addPluginProp("bqTargetTable", bqTargetTable);
-    PluginPropertyUtils.addPluginProp("bqTargetTable2", bqTargetTable2);
+    PluginPropertyUtils.addPluginProp("bqmtTargetTable", bqTargetTable);
+    PluginPropertyUtils.addPluginProp("bqmtTargetTable", bqTargetTable2);
   }
   @Before(order = 1, value = "@BQ_SOURCE_UPDATE_TEST")
   public static void createSourceTables() throws IOException, InterruptedException {