Apache/druid
1
0
Fork 0
mirror of https://github.com/apache/druid.git synced 2025-02-09 11:34:54 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix CI for master (#11522)

Browse Source
This commit is contained in:
Jihoon Son 2021-07-30 15:41:21 -07:00 committed by GitHub
parent 949484728f
commit 98312d54cf
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
benchmarks/src/test/java/org/apache/druid/server/coordinator/BalancerStrategyBenchmark.java
View File

@ -21,7 +21,6 @@ package org.apache.druid.server.coordinator;
import com.google.common.collect.ImmutableMap; import com.google.common.collect.ImmutableMap;
import com.google.common.util.concurrent.MoreExecutors; import com.google.common.util.concurrent.MoreExecutors;
import io.vavr.collection.Stream;
import org.apache.druid.client.ImmutableDruidDataSource; import org.apache.druid.client.ImmutableDruidDataSource;
import org.apache.druid.client.ImmutableDruidServer; import org.apache.druid.client.ImmutableDruidServer;
import org.apache.druid.java.util.common.Intervals; import org.apache.druid.java.util.common.Intervals;
@ -43,7 +42,6 @@ import org.openjdk.jmh.annotations.State;
import org.openjdk.jmh.annotations.Warmup; import org.openjdk.jmh.annotations.Warmup;
import org.openjdk.jmh.infra.Blackhole; import org.openjdk.jmh.infra.Blackhole;
import java.io.IOException;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Collections; import java.util.Collections;
import java.util.Iterator; import java.util.Iterator;
@ -51,6 +49,7 @@ import java.util.List;
import java.util.Random; import java.util.Random;
import java.util.concurrent.Executors; import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
import java.util.stream.IntStream;
@State(Scope.Benchmark) @State(Scope.Benchmark)
@Fork(value = 1) @Fork(value = 1)
@ -81,7 +80,7 @@ public class BalancerStrategyBenchmark
); );
@Setup(Level.Trial) @Setup(Level.Trial)
public void setup() throws IOException public void setup()
{ {
switch (mode) { switch (mode) {
case "50percentOfSegmentsToConsiderPerMove": case "50percentOfSegmentsToConsiderPerMove":
@ -94,7 +93,7 @@ public class BalancerStrategyBenchmark
} }
List<List<DataSegment>> segmentList = new ArrayList<>(NUMBER_OF_SERVERS); List<List<DataSegment>> segmentList = new ArrayList<>(NUMBER_OF_SERVERS);
Stream.range(0, NUMBER_OF_SERVERS).forEach(i -> segmentList.add(new ArrayList<>())); IntStream.range(0, NUMBER_OF_SERVERS).forEach(i -> segmentList.add(new ArrayList<>()));
for (int i = 0; i < numberOfSegments; i++) { for (int i = 0; i < numberOfSegments; i++) {
segmentList.get(RANDOM.nextInt(NUMBER_OF_SERVERS)).add( segmentList.get(RANDOM.nextInt(NUMBER_OF_SERVERS)).add(
new DataSegment( new DataSegment(