mirror of https://github.com/apache/druid.git
1) Left some log lines in the tests... That's no good.
This commit is contained in:
parent
8bd19e9d04
commit
fe5627e119
|
@ -27,7 +27,6 @@ import com.google.common.collect.Iterables;
|
||||||
import com.google.common.collect.Lists;
|
import com.google.common.collect.Lists;
|
||||||
import com.google.common.collect.Maps;
|
import com.google.common.collect.Maps;
|
||||||
import com.google.common.collect.Ordering;
|
import com.google.common.collect.Ordering;
|
||||||
import com.metamx.common.guava.Accumulator;
|
|
||||||
import com.metamx.common.guava.Sequence;
|
import com.metamx.common.guava.Sequence;
|
||||||
import com.metamx.common.guava.Sequences;
|
import com.metamx.common.guava.Sequences;
|
||||||
import com.metamx.druid.PeriodGranularity;
|
import com.metamx.druid.PeriodGranularity;
|
||||||
|
@ -339,16 +338,6 @@ public class GroupByQueryRunnerTest
|
||||||
|
|
||||||
QueryRunner<Row> mergeRunner = new GroupByQueryQueryToolChest().mergeResults(runner);
|
QueryRunner<Row> mergeRunner = new GroupByQueryQueryToolChest().mergeResults(runner);
|
||||||
|
|
||||||
mergeRunner.run(fullQuery).accumulate(null, new Accumulator<Object, Row>()
|
|
||||||
{
|
|
||||||
@Override
|
|
||||||
public Object accumulate(Object o, Row row)
|
|
||||||
{
|
|
||||||
System.out.printf("%d: %s%n", limit, row);
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
});
|
|
||||||
|
|
||||||
TestHelper.assertExpectedObjects(
|
TestHelper.assertExpectedObjects(
|
||||||
Iterables.limit(expectedResults, limit), mergeRunner.run(fullQuery), String.format("limit: %d", limit)
|
Iterables.limit(expectedResults, limit), mergeRunner.run(fullQuery), String.format("limit: %d", limit)
|
||||||
);
|
);
|
||||||
|
|
Loading…
Reference in New Issue