luciano/vmware-go-kcl-v2
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

remove debug code

Browse source
This commit is contained in:
Fabiano Graças 2021-11-08 22:36:18 +01:00 committed by Tao Jiang
parent 2bf65b4386
commit 7538535bff
1 changed files with 0 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
clientlibrary/checkpoint/dynamodb-checkpointer.go
View file

@ -140,9 +140,6 @@ func (checkpointer *DynamoCheckpoint) GetLease(shard *par.ShardStatus, newAssign
var claimRequest string var claimRequest string
if checkpointer.kclConfig.EnableLeaseStealing { if checkpointer.kclConfig.EnableLeaseStealing {
if currentCheckpointClaimRequest, ok := currentCheckpoint[ClaimRequestKey]; ok {
fmt.Printf("aaaaaa %v", currentCheckpointClaimRequest)
}
if currentCheckpointClaimRequest, ok := currentCheckpoint[ClaimRequestKey]; ok && if currentCheckpointClaimRequest, ok := currentCheckpoint[ClaimRequestKey]; ok &&
currentCheckpointClaimRequest.(*types.AttributeValueMemberS).Value != "" { currentCheckpointClaimRequest.(*types.AttributeValueMemberS).Value != "" {
claimRequest = currentCheckpointClaimRequest.(*types.AttributeValueMemberS).Value claimRequest = currentCheckpointClaimRequest.(*types.AttributeValueMemberS).Value