Added comments on the garbage cleanup logic
This commit is contained in:
parent
8ec14baca1
commit
7b0dc0d3e5
1 changed files with 2 additions and 0 deletions
|
|
@ -146,6 +146,8 @@ public class ShutdownTask implements ConsumerTask {
|
||||||
// in the case of RNF Exception.
|
// in the case of RNF Exception.
|
||||||
attemptShardEndCheckpointing(scope, startTime);
|
attemptShardEndCheckpointing(scope, startTime);
|
||||||
} finally {
|
} finally {
|
||||||
|
// If we don't want to cleanup the garbage shard without successful shard end
|
||||||
|
// checkpointing, remove the try finally construct and only execute the methods.
|
||||||
attemptGarbageCollectionOfLeaseAndEnqueueOnFailure(leasePendingDeletion, currentShardLease);
|
attemptGarbageCollectionOfLeaseAndEnqueueOnFailure(leasePendingDeletion, currentShardLease);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue