Skip to content

Commit

Permalink
KAFKA-17422: Adding copySegmentLatch countdown after expiration task …
Browse files Browse the repository at this point in the history
…is over (#17012)

The given test took 5 seconds as the logic was waiting completely for 5 seconds for the expiration task to be completed. Adding copySegmentLatch countdown after expiration task is over

Reviewers: Luke Chen <[email protected]>, Chia-Ping Tsai <[email protected]>
  • Loading branch information
iit2009060 authored Aug 28, 2024
1 parent fb19b3f commit ead9ed5
Showing 1 changed file with 1 addition and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -2133,6 +2133,7 @@ long findLogStartOffset(TopicIdPartition topicIdPartition, UnifiedLog log) {
// wait until copy thread has started copying segment data
copySegmentDataLatch.await();
expirationTask.cleanupExpiredRemoteLogSegments();
copyLogSegmentLatch.countDown();
} catch (RemoteStorageException | ExecutionException | InterruptedException e) {
throw new RuntimeException(e);
}
Expand Down

0 comments on commit ead9ed5

Please sign in to comment.