cryptoe commented on code in PR #19271:
URL: https://github.com/apache/druid/pull/19271#discussion_r3624142186
##########
indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/supervisor/SeekableStreamSupervisor.java:
##########
@@ -1456,12 +1456,12 @@ public int registerNewVersionOfPendingSegment(
// from actively reading to pending completion, etc.
// This is a potential silent-loss window where data will not be
queryable until handoff.
log.info(
- "Could not find any task matching taskAllocatorId[%s] in
supervisor[%s] for upgraded pending segment[%s]"
- + " (upgradedFrom[%s]); it will not be re-announced until handoff.",
- taskAllocatorId,
- supervisorId,
- pendingSegmentRecord.getId(),
- pendingSegmentRecord.getUpgradedFromSegmentId()
+ "Could not find any task matching taskAllocatorId[%s] in
supervisor[%s] for upgraded pending segment[%s]"
+ + " (upgradedFrom[%s]); it will not be re-announced
until handoff.",
+ taskAllocatorId,
+ supervisorId,
+ pendingSegmentRecord.getId(),
+ pendingSegmentRecord.getUpgradedFromSegmentId()
Review Comment:
Its one of those I started changing this file but as I made progress,
realized I donot need to touch this file.
The formatting felt off and hence did a reformat of this piece only.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
