Fix RegexGroupBalanceIT by hosting tablets

dlmarion · Dec 6, 2023 · ff325e8 · ff325e8
1 parent 8f88fbe
commit ff325e8
Showing 1 changed file with 3 additions and 4 deletions.
diff --git a/test/src/main/java/org/apache/accumulo/test/functional/RegexGroupBalanceIT.java b/test/src/main/java/org/apache/accumulo/test/functional/RegexGroupBalanceIT.java
@@ -32,6 +32,7 @@
 import org.apache.accumulo.core.client.Scanner;
 import org.apache.accumulo.core.client.TableNotFoundException;
 import org.apache.accumulo.core.client.admin.NewTableConfiguration;
+import org.apache.accumulo.core.client.admin.TabletHostingGoal;
 import org.apache.accumulo.core.conf.Property;
 import org.apache.accumulo.core.data.Key;
 import org.apache.accumulo.core.data.TableId;
@@ -45,13 +46,11 @@
 import org.apache.accumulo.miniclusterImpl.MiniAccumuloConfigImpl;
 import org.apache.commons.lang3.mutable.MutableInt;
 import org.apache.hadoop.io.Text;
-import org.junit.jupiter.api.Disabled;
 import org.junit.jupiter.api.Test;
 
 import com.google.common.collect.HashBasedTable;
 import com.google.common.collect.Table;
 
-@Disabled // ELASTICITY_TODO
 public class RegexGroupBalanceIT extends ConfigurableMacBase {
 
   @Override
@@ -90,8 +89,8 @@ public void testBalancing() throws Exception {
       props.put(RegexGroupBalancer.WAIT_TIME_PROPERTY, "50ms");
       props.put(Property.TABLE_LOAD_BALANCER.getKey(), RegexGroupBalancer.class.getName());
 
-      client.tableOperations().create(tablename,
-          new NewTableConfiguration().setProperties(props).withSplits(splits));
+      client.tableOperations().create(tablename, new NewTableConfiguration().setProperties(props)
+          .withSplits(splits).withInitialHostingGoal(TabletHostingGoal.ALWAYS));
 
       while (true) {
         Thread.sleep(250);