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 9cf7fe68a..8f8239910 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 @@ -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 {