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

KafkaIndexTask remove branch with unreachable code (#5434)

This commit is contained in:
Clint Wylie 2018-03-02 17:26:12 -08:00 committed by Gian Merlino
parent b63f1c0e45
commit f948066710
1 changed files with 7 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
extensions-core/kafka-indexing-service/src/main/java/io/druid/indexing/kafka/KafkaIndexTask.java
View File

@ -856,17 +856,13 @@ public class KafkaIndexTask extends AbstractTask implements ChatHandler
} }
for (SegmentsAndMetadata handedOff : handedOffList) { for (SegmentsAndMetadata handedOff : handedOffList) {
if (handedOff == null) { log.info(
log.warn("Handoff failed for segments %s", handedOff.getSegments()); "Handoff completed for segments[%s] with metadata[%s].",
} else { Joiner.on(", ").join(
log.info( handedOff.getSegments().stream().map(DataSegment::getIdentifier).collect(Collectors.toList())
"Handoff completed for segments[%s] with metadata[%s].", ),
Joiner.on(", ").join( Preconditions.checkNotNull(handedOff.getCommitMetadata(), "commitMetadata")
handedOff.getSegments().stream().map(DataSegment::getIdentifier).collect(Collectors.toList()) );
),
Preconditions.checkNotNull(handedOff.getCommitMetadata(), "commitMetadata")
);
}
} }
} }
catch (InterruptedException | RejectedExecutionException e) { catch (InterruptedException | RejectedExecutionException e) {