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());

Reply via email to