From 2f722d9cd2cfcaa038e0b563a8a908d7bb6473d4 Mon Sep 17 00:00:00 2001
From: Tony Wang <wwwjfy@gmail.com>
Date: Fri, 9 Nov 2018 15:08:47 +0800
Subject: [PATCH] fix periodic checkpoint not triggered

when initialized, largestPair is empty and IsLessThan always return
false
---
 cmd/consumer/main.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/cmd/consumer/main.go b/cmd/consumer/main.go
index 647b472..4fd7a7e 100644
--- a/cmd/consumer/main.go
+++ b/cmd/consumer/main.go
@@ -29,7 +29,7 @@ func (srp *sampleRecordProcessor) Initialize(shardID string, checkpointer kcl.Ch
 }
 
 func (srp *sampleRecordProcessor) shouldUpdateSequence(pair kcl.SequencePair) bool {
-	return srp.largestPair.IsLessThan(pair)
+	return srp.largestPair.IsNil() || srp.largestPair.IsLessThan(pair)
 }
 
 func (srp *sampleRecordProcessor) ProcessRecords(records []kcl.Record) error {