luciano/amazon-kinesis-client
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Merge pull request #794 from tiaanl/silence-empty-warning

Browse source 
Silence warning when there are no stale streams to delete
This commit is contained in:
antoshen 2021-06-22 14:48:01 -07:00 committed by GitHub
commit 7f18330ebd
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
amazon-kinesis-client/src/main/java/software/amazon/kinesis/coordinator/Scheduler.java
View file

@ -565,10 +565,12 @@ public class Scheduler implements Runnable {
final Set<StreamIdentifier> staleStreamIdsToBeRevived = staleStreamIdDeletionDecisionMap.get(true); final Set<StreamIdentifier> staleStreamIdsToBeRevived = staleStreamIdDeletionDecisionMap.get(true);
removeStreamsFromStaleStreamsList(staleStreamIdsToBeRevived); removeStreamsFromStaleStreamsList(staleStreamIdsToBeRevived);
if (!staleStreamDeletionMap.isEmpty()) {
log.warn( log.warn(
"Streams enqueued for deletion for lease table cleanup along with their scheduled time for deletion: {} ", "Streams enqueued for deletion for lease table cleanup along with their scheduled time for deletion: {} ",
staleStreamDeletionMap.entrySet().stream().collect(Collectors.toMap(Map.Entry::getKey, staleStreamDeletionMap.entrySet().stream().collect(Collectors.toMap(Map.Entry::getKey,
entry -> entry.getValue().plus(waitPeriodToDeleteOldStreams)))); entry -> entry.getValue().plus(waitPeriodToDeleteOldStreams))));
}
streamSyncWatch.reset().start(); streamSyncWatch.reset().start();