Apache
/
druid
mirror of https://github.com/apache/druid.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix dead code in IndexTask.collectIntervalsAndShardSpecs() (#7746)

This commit is contained in:
Jonathan Wei 2019-05-25 10:12:15 -07:00 committed by Fangjin Yang
parent 7eac685e47
commit c97eb93e16
1 changed files with 5 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
indexing-service/src/main/java/org/apache/druid/indexing/common/task/IndexTask.java
View File

@ -731,8 +731,6 @@ public class IndexTask extends AbstractTask implements ChatHandler
final Map<Interval, Optional<HyperLogLogCollector>> hllCollectors = new TreeMap<>( final Map<Interval, Optional<HyperLogLogCollector>> hllCollectors = new TreeMap<>(
Comparators.intervalsByStartThenEnd() Comparators.intervalsByStartThenEnd()
); );
int thrownAway = 0;
int unparseable = 0;
final Granularity queryGranularity = granularitySpec.getQueryGranularity(); final Granularity queryGranularity = granularitySpec.getQueryGranularity();
try ( try (
@ -807,12 +805,13 @@ public class IndexTask extends AbstractTask implements ChatHandler
} }
// These metrics are reported in generateAndPublishSegments() // These metrics are reported in generateAndPublishSegments()
if (thrownAway > 0) { if (determinePartitionsMeters.getThrownAway() > 0) {
log.warn("Unable to find a matching interval for [%,d] events", thrownAway); log.warn("Unable to find a matching interval for [%,d] events", determinePartitionsMeters.getThrownAway());
} }
if (unparseable > 0) { if (determinePartitionsMeters.getUnparseable() > 0) {
log.warn("Unable to parse [%,d] events", unparseable); log.warn("Unable to parse [%,d] events", determinePartitionsMeters.getUnparseable());
} }
return hllCollectors; return hllCollectors;
} }