diff --git a/clientlibrary/checkpoint/dynamodb-checkpointer.go b/clientlibrary/checkpoint/dynamodb-checkpointer.go index 4465f5a..091700b 100644 --- a/clientlibrary/checkpoint/dynamodb-checkpointer.go +++ b/clientlibrary/checkpoint/dynamodb-checkpointer.go @@ -140,9 +140,6 @@ func (checkpointer *DynamoCheckpoint) GetLease(shard *par.ShardStatus, newAssign var claimRequest string if checkpointer.kclConfig.EnableLeaseStealing { - if currentCheckpointClaimRequest, ok := currentCheckpoint[ClaimRequestKey]; ok { - fmt.Printf("aaaaaa %v", currentCheckpointClaimRequest) - } if currentCheckpointClaimRequest, ok := currentCheckpoint[ClaimRequestKey]; ok && currentCheckpointClaimRequest.(*types.AttributeValueMemberS).Value != "" { claimRequest = currentCheckpointClaimRequest.(*types.AttributeValueMemberS).Value