luciano/amazon-kinesis-client
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Revert "Added debug logs in KinesisLocalFileDataCreator"

Browse source 
This reverts commit 1ff00d0b01.
This commit is contained in:
parijas 2018-01-10 11:12:04 -08:00
parent 1ff00d0b01
commit 2a73bbe671
1 changed files with 1 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
src/test/java/com/amazonaws/services/kinesis/clientlibrary/proxies/util/KinesisLocalFileDataCreator.java
View file

@ -119,9 +119,7 @@ public class KinesisLocalFileDataCreator {
maxSequenceNumber = new BigInteger(endingSequenceNumber); maxSequenceNumber = new BigInteger(endingSequenceNumber);
} }
if (maxSequenceNumber.compareTo(sequenceNumber) != 1) { if (maxSequenceNumber.compareTo(sequenceNumber) != 1) {
throw new IllegalArgumentException("Not enough space in shard. maxSequenceNumber: " throw new IllegalArgumentException("Not enough space in shard");
+ maxSequenceNumber.toString() + ", sequenceNumber: " + sequenceNumber.toString()
+ ", sequenceNumberIncrement: " + sequenceNumberIncrement.toString());
} }
String partitionKey = String partitionKey =
PARTITION_KEY_PREFIX + shard.getShardId() + generateRandomString(PARTITION_KEY_LENGTH); PARTITION_KEY_PREFIX + shard.getShardId() + generateRandomString(PARTITION_KEY_LENGTH);