diff --git a/test/src/test/java/cn/edu/tsinghua/iginx/integration/expansion/mysql/MySQLCapacityExpansionIT.java b/test/src/test/java/cn/edu/tsinghua/iginx/integration/expansion/mysql/MySQLCapacityExpansionIT.java index 53d7e635a9..f75fbea476 100644 --- a/test/src/test/java/cn/edu/tsinghua/iginx/integration/expansion/mysql/MySQLCapacityExpansionIT.java +++ b/test/src/test/java/cn/edu/tsinghua/iginx/integration/expansion/mysql/MySQLCapacityExpansionIT.java @@ -18,7 +18,7 @@ public MySQLCapacityExpansionIT() { StorageEngineType.relational, "engine:mysql, username:root," + "meta_properties_path:dataSources/relational/src/main/resources/mysql-meta-template.properties", - new MySQLHistoryDataGenerator()); + new MySQLHistoryDataGenerator()); ConfLoader conf = new ConfLoader(Controller.CONFIG_FILE); DBConf dbConf = conf.loadDBConf(conf.getStorageType()); Constant.oriPort = dbConf.getDBCEPortMap().get(Constant.ORI_PORT_NAME); diff --git a/test/src/test/java/cn/edu/tsinghua/iginx/integration/expansion/postgresql/PostgreSQLCapacityExpansionIT.java b/test/src/test/java/cn/edu/tsinghua/iginx/integration/expansion/postgresql/PostgreSQLCapacityExpansionIT.java index bbd7957785..0ced1e22a1 100644 --- a/test/src/test/java/cn/edu/tsinghua/iginx/integration/expansion/postgresql/PostgreSQLCapacityExpansionIT.java +++ b/test/src/test/java/cn/edu/tsinghua/iginx/integration/expansion/postgresql/PostgreSQLCapacityExpansionIT.java @@ -15,7 +15,10 @@ public class PostgreSQLCapacityExpansionIT extends BaseCapacityExpansionIT { private static final Logger LOGGER = LoggerFactory.getLogger(PostgreSQLCapacityExpansionIT.class); public PostgreSQLCapacityExpansionIT() { - super(StorageEngineType.relational, "engine:postgresql, username:postgres, password:postgres", new PostgreSQLHistoryDataGenerator()); + super( + StorageEngineType.relational, + "engine:postgresql, username:postgres, password:postgres", + new PostgreSQLHistoryDataGenerator()); ConfLoader conf = new ConfLoader(Controller.CONFIG_FILE); DBConf dbConf = conf.loadDBConf(conf.getStorageType()); Constant.oriPort = dbConf.getDBCEPortMap().get(Constant.ORI_PORT_NAME);