This is an automated email from the ASF dual-hosted git repository. cshannon pushed a commit to branch elasticity in repository https://gitbox.apache.org/repos/asf/accumulo.git
The following commit(s) were added to refs/heads/elasticity by this push: new 20681b37a0 Minor test updates and cleanup related to #4650 20681b37a0 is described below commit 20681b37a01e97738d5c45b1c475f233aa071bb0 Author: Christopher L. Shannon <cshan...@apache.org> AuthorDate: Fri Jun 21 11:29:10 2024 -0400 Minor test updates and cleanup related to #4650 --- .../org/apache/accumulo/server/init/InitialConfiguration.java | 1 - .../java/org/apache/accumulo/test/functional/WALSunnyDayIT.java | 8 ++++++-- 2 files changed, 6 insertions(+), 3 deletions(-) diff --git a/server/base/src/main/java/org/apache/accumulo/server/init/InitialConfiguration.java b/server/base/src/main/java/org/apache/accumulo/server/init/InitialConfiguration.java index 98a3ac8217..4b7adfe176 100644 --- a/server/base/src/main/java/org/apache/accumulo/server/init/InitialConfiguration.java +++ b/server/base/src/main/java/org/apache/accumulo/server/init/InitialConfiguration.java @@ -94,7 +94,6 @@ class InitialConfiguration { FateSchema.TxColumnFamily.STR_NAME); initialFateTableConf.put(Property.TABLE_LOCALITY_GROUPS.getKey(), "status"); - // TODO: What other configs do we want for this table? initialScanRefTableConf.putAll(commonConfig); int max = hadoopConf.getInt("dfs.replication.max", 512); diff --git a/test/src/main/java/org/apache/accumulo/test/functional/WALSunnyDayIT.java b/test/src/main/java/org/apache/accumulo/test/functional/WALSunnyDayIT.java index 5fb10db0c6..2d085c8893 100644 --- a/test/src/main/java/org/apache/accumulo/test/functional/WALSunnyDayIT.java +++ b/test/src/main/java/org/apache/accumulo/test/functional/WALSunnyDayIT.java @@ -149,14 +149,18 @@ public class WALSunnyDayIT extends ConfigurableMacBase { Map<KeyExtent,List<String>> markers = getRecoveryMarkers(c); // log.debug("markers " + markers); // There should be markers for the created table and also the Fate and ScanRef tables - assertEquals(3, markers.size(), "two tablets should have markers"); + assertEquals(3, markers.size(), "three tablets should have markers"); assertTrue( markers.keySet().stream().anyMatch(extent -> extent.tableId().canonical().equals("1")), "tableId of the keyExtent should be 1"); assertTrue( markers.keySet().stream() .anyMatch(extent -> extent.tableId().equals(AccumuloTable.FATE.tableId())), - "tableId of the FateTable can't be found"); + "tableId of the Fate table can't be found"); + assertTrue( + markers.keySet().stream() + .anyMatch(extent -> extent.tableId().equals(AccumuloTable.SCAN_REF.tableId())), + "tableId of the ScanRef table can't be found"); // put some data in the WAL assertEquals(0, cluster.exec(SetGoalState.class, "NORMAL").getProcess().waitFor());