From c63d62b8db2269491b6d2a6a8d2a4f9737159fc1 Mon Sep 17 00:00:00 2001 From: Sahil Palvia Date: Tue, 17 Apr 2018 15:40:08 -0700 Subject: [PATCH] Removing unnecessary log statement. --- .../kinesis/coordinator/RecordProcessorCheckpointer.java | 8 -------- 1 file changed, 8 deletions(-) diff --git a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/coordinator/RecordProcessorCheckpointer.java b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/coordinator/RecordProcessorCheckpointer.java index 8413b36f..014d9cd2 100644 --- a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/coordinator/RecordProcessorCheckpointer.java +++ b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/coordinator/RecordProcessorCheckpointer.java @@ -113,10 +113,6 @@ public class RecordProcessorCheckpointer implements IRecordProcessorCheckpointer + subSequenceNumber); } - if (log.isDebugEnabled()) { - log.debug("Validated checkpoint sequence number {} for {}, token {}", sequenceNumber, - shardInfo.shardId(), shardInfo.concurrencyToken()); - } /* * If there isn't a last checkpoint value, we only care about checking the upper bound. * If there is a last checkpoint value, we want to check both the lower and upper bound. @@ -186,10 +182,6 @@ public class RecordProcessorCheckpointer implements IRecordProcessorCheckpointer + subSequenceNumber); } - if (log.isDebugEnabled()) { - log.debug("Validated prepareCheckpoint sequence number {} for {}, token {}", sequenceNumber, - shardInfo.shardId(), shardInfo.concurrencyToken()); - } /* * If there isn't a last checkpoint value, we only care about checking the upper bound. * If there is a last checkpoint value, we want to check both the lower and upper bound.