[accumulo] branch 1451-external-compactions-feature updated: split table in external compaction IT

[kt...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

kturner pushed a commit to branch 1451-external-compactions-feature
in repository https://gitbox.apache.org/repos/asf/accumulo.git


The following commit(s) were added to refs/heads/1451-external-compactions-feature by this push:
     new 29449ea  split table in external compaction IT
29449ea is described below

commit 29449ea976be2f8d7fcae8ac35adb10927770033
Author: Keith Turner <kt...@apache.org>
AuthorDate: Tue Apr 13 14:49:20 2021 -0400

    split table in external compaction IT
---
 .../main/java/org/apache/accumulo/test/ExternalCompactionIT.java   | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git a/test/src/main/java/org/apache/accumulo/test/ExternalCompactionIT.java b/test/src/main/java/org/apache/accumulo/test/ExternalCompactionIT.java
index c74b04e..837b964 100644
--- a/test/src/main/java/org/apache/accumulo/test/ExternalCompactionIT.java
+++ b/test/src/main/java/org/apache/accumulo/test/ExternalCompactionIT.java
@@ -22,6 +22,8 @@ import java.io.IOException;
 import java.util.List;
 import java.util.Map;
 import java.util.Map.Entry;
+import java.util.SortedSet;
+import java.util.TreeSet;
 
 import org.apache.accumulo.compactor.CompactionEnvironment.CompactorIterEnv;
 import org.apache.accumulo.compactor.Compactor;
@@ -49,6 +51,7 @@ import org.apache.accumulo.core.spi.compaction.SimpleCompactionDispatcher;
 import org.apache.accumulo.miniclusterImpl.MiniAccumuloConfigImpl;
 import org.apache.accumulo.test.functional.ConfigurableMacBase;
 import org.apache.hadoop.conf.Configuration;
+import org.apache.hadoop.io.Text;
 import org.junit.Assert;
 import org.junit.Test;
 
@@ -123,6 +126,10 @@ public class ExternalCompactionIT extends ConfigurableMacBase {
       compact(client, table1, 2, "DCQ1");
       verify(client, table1, 2);
 
+      SortedSet<Text> splits = new TreeSet<>();
+      splits.add(new Text("r:4"));
+      client.tableOperations().addSplits(table2, splits);
+
       compact(client, table2, 3, "DCQ2");
       verify(client, table2, 3);