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