Added metric to record when a lease cannot be taken due to a Conditio…

…nalCheckFailedException
awslabs · Mar 31, 2022 · a344ee4 · a344ee4
1 parent 862fabb
commit a344ee4
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/...esis-client/src/main/java/software/amazon/kinesis/leases/dynamodb/DynamoDBLeaseTaker.java b/...esis-client/src/main/java/software/amazon/kinesis/leases/dynamodb/DynamoDBLeaseTaker.java
@@ -236,6 +236,7 @@ synchronized Map<String, Lease> takeLeases(Callable<Long> timeProvider)
  }
 
  scope.addData("TakenLeases", takenLeases.size(), StandardUnit.COUNT, MetricsLevel.SUMMARY);
+ scope.addData("UntakenLeases", untakenLeaseKeys.size(), StandardUnit.COUNT, MetricsLevel.SUMMARY);
  } finally {
  MetricsUtil.endScope(scope);
  }