From 68899c888a7f5fe385891c23d001fbb572352b77 Mon Sep 17 00:00:00 2001 From: sabmeua Date: Tue, 23 Jun 2020 18:19:58 +0900 Subject: [PATCH] Fix variables typo --- samples/sample_kcl.rb | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/samples/sample_kcl.rb b/samples/sample_kcl.rb index aee132b..08fca8b 100755 --- a/samples/sample_kcl.rb +++ b/samples/sample_kcl.rb @@ -33,9 +33,9 @@ def process_records(process_records_input) # Checking if last sequenceNumber is not nil and if it has been more than @check_freq_seconds before checkpointing. if last_seq && - ((@last_checkpoint_time.nil?) || ((DateTime.now - @last_checpoint_time) * 86400 > @checkpoint_freq_seconds)) + ((@last_checkpoint_time.nil?) || ((DateTime.now - @last_checkpoint_time) * 86400 > @checkpoint_freq_seconds)) checkpoint_helper(process_records_input.checkpointer, last_seq) - @last_checpoint_time = DateTime.now + @last_checkpoint_time = DateTime.now end end