Added debug logs in KinesisLocalFileDataCreator

awslabs · Jan 9, 2018 · 1ff00d0 · 1ff00d0
1 parent f15c0fd
commit 1ff00d0
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...om/amazonaws/services/kinesis/clientlibrary/proxies/util/KinesisLocalFileDataCreator.java b/...om/amazonaws/services/kinesis/clientlibrary/proxies/util/KinesisLocalFileDataCreator.java
@@ -119,7 +119,9 @@ public static File generateTempDataFile(List<Shard> shardList, int numRecordsPer
                         maxSequenceNumber = new BigInteger(endingSequenceNumber);
                     }
                     if (maxSequenceNumber.compareTo(sequenceNumber) != 1) {
-                        throw new IllegalArgumentException("Not enough space in shard");
+                        throw new IllegalArgumentException("Not enough space in shard. maxSequenceNumber: "
+                            + maxSequenceNumber.toString() + ", sequenceNumber: " + sequenceNumber.toString()
+                        + ", sequenceNumberIncrement: " + sequenceNumberIncrement.toString());
                     }
                     String partitionKey =
                             PARTITION_KEY_PREFIX + shard.getShardId() + generateRandomString(PARTITION_KEY_LENGTH);