diff --git a/src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/ShutdownFuture.java b/src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/ShutdownFuture.java index f531749a..8ee96537 100644 --- a/src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/ShutdownFuture.java +++ b/src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/ShutdownFuture.java @@ -48,7 +48,7 @@ class ShutdownFuture implements Future { private long outstandingRecordProcessors(long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException { - long startNanos = System.nanoTime(); + final long startNanos = System.nanoTime(); // // Awaiting for all ShardConsumer/RecordProcessors to be notified that a shutdown has been requested. @@ -58,8 +58,9 @@ class ShutdownFuture implements Future { // if (!notificationCompleteLatch.await(timeout, unit)) { long awaitingNotification = notificationCompleteLatch.getCount(); - log.info("Awaiting " + awaitingNotification + " record processors to complete shutdown notification"); long awaitingFinalShutdown = shutdownCompleteLatch.getCount(); + log.info("Awaiting " + awaitingNotification + " record processors to complete shutdown notification, and " + + awaitingFinalShutdown + " awaiting final shutdown"); if (awaitingFinalShutdown != 0) { // // The number of record processor awaiting final shutdown should be a superset of the those awaiting