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

fixing expectation

Browse source
This commit is contained in:
Chunxue Yang 2020-07-28 13:43:56 -07:00
parent 6738087a8f
commit 38cef8963a
1 changed files with 3 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
src/main/java/com/amazonaws/services/kinesis/leases/impl/LeaseSerializer.java
View file

@ -141,7 +141,9 @@ public class LeaseSerializer implements ILeaseSerializer<Lease> {
public Map<String, ExpectedAttributeValue> getDynamoExistantExpectation(final String leaseKey) { public Map<String, ExpectedAttributeValue> getDynamoExistantExpectation(final String leaseKey) {
Map<String, ExpectedAttributeValue> result = new HashMap<>(); Map<String, ExpectedAttributeValue> result = new HashMap<>();
ExpectedAttributeValue expectedAV = new ExpectedAttributeValue(DynamoUtils.createAttributeValue(leaseKey)); ExpectedAttributeValue expectedAV = new ExpectedAttributeValue();
expectedAV.setValue(DynamoUtils.createAttributeValue(leaseKey));
expectedAV.setExists(true);
result.put(LEASE_KEY_KEY, expectedAV); result.put(LEASE_KEY_KEY, expectedAV);
return result; return result;