From ffe82e2656aef24fde86debf7097423b8389606c Mon Sep 17 00:00:00 2001
From: posac <michal.posacki@psck.io>
Date: Thu, 2 Nov 2017 17:33:45 +0100
Subject: [PATCH] Issue #211 Application didn't checkpoint at end of shard

---
 .../clientlibrary/lib/worker/RecordProcessorCheckpointer.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/RecordProcessorCheckpointer.java b/src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/RecordProcessorCheckpointer.java
index 72e18d73..ac6081d9 100644
--- a/src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/RecordProcessorCheckpointer.java
+++ b/src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/RecordProcessorCheckpointer.java
@@ -284,7 +284,7 @@ class RecordProcessorCheckpointer implements IRecordProcessorCheckpointer {
             checkpointToRecord = ExtendedSequenceNumber.SHARD_END;
         }
         // Don't checkpoint a value we already successfully checkpointed
-        if (extendedSequenceNumber != null && !extendedSequenceNumber.equals(lastCheckpointValue)) {
+        if (checkpointToRecord != null && !checkpointToRecord.equals(lastCheckpointValue)) {
             try {
                 if (LOG.isDebugEnabled()) {
                     LOG.debug("Setting " + shardInfo.getShardId() + ", token " + shardInfo.getConcurrencyToken()