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 <[email protected]>
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());