From 0e910a1dbc5a4457fd2218e9830476bf831e964a Mon Sep 17 00:00:00 2001 From: Micah Jaffe <31011877+micah-jaffe@users.noreply.github.com> Date: Tue, 13 Aug 2019 11:49:40 -0700 Subject: [PATCH] Updated logging message around ShardEnd checkpointing failures (#590) --- .../kinesis/clientlibrary/lib/worker/ShutdownTask.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/ShutdownTask.java b/src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/ShutdownTask.java index f1e15ae7..f062d745 100644 --- a/src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/ShutdownTask.java +++ b/src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/ShutdownTask.java @@ -114,7 +114,8 @@ class ShutdownTask implements ITask { if ((lastCheckpointValue == null) || (!lastCheckpointValue.equals(ExtendedSequenceNumber.SHARD_END))) { throw new IllegalArgumentException("Application didn't checkpoint at end of shard " - + shardInfo.getShardId()); + + shardInfo.getShardId() + ". Application must checkpoint upon shutdown. " + + "See IRecordProcessor.shutdown javadocs for more information."); } } LOG.debug("Shutting down retrieval strategy.");