Skip to content

Commit 37c8ea8

Browse files
committed
Fix build
1 parent 7cf46f9 commit 37c8ea8

File tree

2 files changed

+3
-5
lines changed

2 files changed

+3
-5
lines changed

server/manager/src/test/java/org/apache/accumulo/manager/compaction/queue/CompactionJobPriorityQueueTest.java

+1-2
Original file line numberDiff line numberDiff line change
@@ -37,15 +37,14 @@
3737
import org.apache.accumulo.core.spi.compaction.CompactorGroupId;
3838
import org.apache.accumulo.core.util.Pair;
3939
import org.apache.accumulo.core.util.compaction.CompactionJobPrioritizer;
40-
import org.apache.accumulo.core.util.compaction.CompactorGroupIdImpl;
4140
import org.apache.accumulo.manager.compaction.queue.CompactionJobQueues.MetaJob;
4241
import org.apache.hadoop.io.Text;
4342
import org.easymock.EasyMock;
4443
import org.junit.jupiter.api.Test;
4544

4645
public class CompactionJobPriorityQueueTest {
4746

48-
private static final CompactorGroupId GROUP = CompactorGroupIdImpl.groupId("TEST");
47+
private static final CompactorGroupId GROUP = CompactorGroupId.of("TEST");
4948

5049
@Test
5150
public void testTabletFileReplacement() {

server/manager/src/test/java/org/apache/accumulo/manager/compaction/queue/CompactionJobQueuesTest.java

+2-3
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,6 @@
3939
import org.apache.accumulo.core.spi.compaction.CompactionKind;
4040
import org.apache.accumulo.core.spi.compaction.CompactorGroupId;
4141
import org.apache.accumulo.core.util.compaction.CompactionJobImpl;
42-
import org.apache.accumulo.core.util.compaction.CompactorGroupIdImpl;
4342
import org.apache.hadoop.io.Text;
4443
import org.junit.jupiter.api.Test;
4544

@@ -57,8 +56,8 @@ public void testAddPollRaceCondition() throws Exception {
5756
final int numToAdd = 100_000;
5857

5958
CompactionJobQueues jobQueues = new CompactionJobQueues(numToAdd + 1);
60-
CompactorGroupId[] groups = Stream.of("G1", "G2", "G3")
61-
.map(s -> CompactorGroupIdImpl.groupId(s)).toArray(l -> new CompactorGroupId[l]);
59+
CompactorGroupId[] groups =
60+
Stream.of("G1", "G2", "G3").map(CompactorGroupId::of).toArray(CompactorGroupId[]::new);
6261

6362
var executor = Executors.newFixedThreadPool(groups.length);
6463

0 commit comments

Comments
 (0)