From 037dd7f6c811391d9f23e9b573d589a6bff9bba9 Mon Sep 17 00:00:00 2001 From: Aravinda Kidambi Srinivasan Date: Thu, 7 Nov 2024 14:55:30 -0800 Subject: [PATCH] Fix typo THROUGHOUT_PUT_KBPS --- .../leases/dynamodb/DynamoDBLeaseSerializer.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/dynamodb/DynamoDBLeaseSerializer.java b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/dynamodb/DynamoDBLeaseSerializer.java index 16d719bf..0ad34b69 100644 --- a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/dynamodb/DynamoDBLeaseSerializer.java +++ b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/dynamodb/DynamoDBLeaseSerializer.java @@ -54,7 +54,7 @@ public class DynamoDBLeaseSerializer implements LeaseSerializer { private static final String CHILD_SHARD_IDS_KEY = "childShardIds"; private static final String STARTING_HASH_KEY = "startingHashKey"; private static final String ENDING_HASH_KEY = "endingHashKey"; - private static final String THROUGHOUT_PUT_KBPS = "throughputKBps"; + private static final String THROUGHPUT_KBPS = "throughputKBps"; private static final String CHECKPOINT_SEQUENCE_NUMBER_KEY = "checkpoint"; static final String CHECKPOINT_OWNER = "checkpointOwner"; static final String LEASE_OWNER_KEY = "leaseOwner"; @@ -113,7 +113,7 @@ public class DynamoDBLeaseSerializer implements LeaseSerializer { } if (lease.throughputKBps() != null) { - result.put(THROUGHOUT_PUT_KBPS, DynamoUtils.createAttributeValue(lease.throughputKBps())); + result.put(THROUGHPUT_KBPS, DynamoUtils.createAttributeValue(lease.throughputKBps())); } if (lease.checkpointOwner() != null) { @@ -155,8 +155,8 @@ public class DynamoDBLeaseSerializer implements LeaseSerializer { leaseToUpdate.hashKeyRange(HashKeyRangeForLease.deserialize(startingHashKey, endingHashKey)); } - if (DynamoUtils.safeGetDouble(dynamoRecord, THROUGHOUT_PUT_KBPS) != null) { - leaseToUpdate.throughputKBps(DynamoUtils.safeGetDouble(dynamoRecord, THROUGHOUT_PUT_KBPS)); + if (DynamoUtils.safeGetDouble(dynamoRecord, THROUGHPUT_KBPS) != null) { + leaseToUpdate.throughputKBps(DynamoUtils.safeGetDouble(dynamoRecord, THROUGHPUT_KBPS)); } if (DynamoUtils.safeGetString(dynamoRecord, CHECKPOINT_OWNER) != null) { @@ -466,7 +466,7 @@ public class DynamoDBLeaseSerializer implements LeaseSerializer { .value(DynamoUtils.createAttributeValue(lease.throughputKBps())) .action(AttributeAction.PUT) .build(); - result.put(THROUGHOUT_PUT_KBPS, avu); + result.put(THROUGHPUT_KBPS, avu); return result; }