diff --git a/contrib/terraform-testing-infrastructure/modules/config-files/templates/cluster.yaml.tftpl b/contrib/terraform-testing-infrastructure/modules/config-files/templates/cluster.yaml.tftpl index 8012282a..4919b3f7 100644 --- a/contrib/terraform-testing-infrastructure/modules/config-files/templates/cluster.yaml.tftpl +++ b/contrib/terraform-testing-infrastructure/modules/config-files/templates/cluster.yaml.tftpl @@ -58,5 +58,8 @@ compaction: # NUM_SSERVERS is set then it will override sservers_per_host. # tservers_per_host: 1 -sservers_per_host: 1 - +sservers_per_host: + - default: 1 +compactors_per_host: + - q1: 1 + - q2: 1 diff --git a/contrib/terraform-testing-infrastructure/modules/config-files/templates/install_sw.sh.tftpl b/contrib/terraform-testing-infrastructure/modules/config-files/templates/install_sw.sh.tftpl index bb1e1def..38720134 100644 --- a/contrib/terraform-testing-infrastructure/modules/config-files/templates/install_sw.sh.tftpl +++ b/contrib/terraform-testing-infrastructure/modules/config-files/templates/install_sw.sh.tftpl @@ -150,7 +150,7 @@ else git clone ${accumulo_testing_repo} accumulo-testing-repo cd accumulo-testing-repo git checkout ${accumulo_testing_branch_name} - ${software_root}/apache-maven/apache-maven-${maven_version}/bin/mvn -ntp clean package -DskipTests -DskipITs + ${software_root}/apache-maven/apache-maven-${maven_version}/bin/mvn -ntp clean package -DskipTests -DskipITs -Daccumulo.version=${accumulo_version} fi # diff --git a/src/main/java/org/apache/accumulo/testing/continuous/CreateTable.java b/src/main/java/org/apache/accumulo/testing/continuous/CreateTable.java index ab952cc2..55d9e691 100644 --- a/src/main/java/org/apache/accumulo/testing/continuous/CreateTable.java +++ b/src/main/java/org/apache/accumulo/testing/continuous/CreateTable.java @@ -108,6 +108,9 @@ private static Map getProps(ContinuousEnv env, String propType) { String[] propArray = env.getTestProperty(propType).split(" "); Map propMap = new HashMap<>(); for (String prop : propArray) { + if (prop.isBlank()) { + continue; + } log.debug("prop: {}", prop); String[] kv = prop.split("="); propMap.put(kv[0], kv[1]); diff --git a/src/main/java/org/apache/accumulo/testing/randomwalk/concurrent/Config.java b/src/main/java/org/apache/accumulo/testing/randomwalk/concurrent/Config.java index fdf5c309..9c86e01e 100644 --- a/src/main/java/org/apache/accumulo/testing/randomwalk/concurrent/Config.java +++ b/src/main/java/org/apache/accumulo/testing/randomwalk/concurrent/Config.java @@ -69,6 +69,9 @@ static Setting s(Property property, long min, long max) { final Property TSERV_TABLET_SPLIT_FINDMIDPOINT_MAXOPEN_deprecated = Property.TSERV_TABLET_SPLIT_FINDMIDPOINT_MAXOPEN; + @SuppressWarnings("deprecation") + final Property TABLE_MINC_COMPACT_IDLETIME_deprecated = Property.TABLE_MINC_COMPACT_IDLETIME; + // @formatter:off final Setting[] settings = { s(Property.TSERV_BLOOM_LOAD_MAXCONCURRENT, 1, 10), @@ -103,7 +106,7 @@ static Setting s(Property property, long min, long max) { final Setting[] tableSettings = { s(Property.TABLE_MAJC_RATIO, 1, 10), s(Property.TABLE_SPLIT_THRESHOLD, 10 * 1024, 10L * 1024 * 1024 * 1024), - s(Property.TABLE_MINC_COMPACT_IDLETIME, 100, 100 * 60 * 60 * 1000L), + s(TABLE_MINC_COMPACT_IDLETIME_deprecated, 100, 100 * 60 * 60 * 1000L), s(Property.TABLE_SCAN_MAXMEM, 10 * 1024, 10 * 1024 * 1024), s(Property.TABLE_FILE_COMPRESSED_BLOCK_SIZE, 10 * 1024, 10 * 1024 * 1024L), s(Property.TABLE_FILE_COMPRESSED_BLOCK_SIZE_INDEX, 10 * 1024, 10 * 1024 * 1024L),