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

Get rid of unused skipTableCheck (#39)

Browse source
This commit is contained in:
Tao Jiang 2019-10-03 20:45:34 -05:00 committed by Tao Jiang
parent 46fea317de
commit 4f79203f44
1 changed files with 1 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -61,7 +61,6 @@ type DynamoCheckpoint struct {
svc dynamodbiface.DynamoDBAPI svc dynamodbiface.DynamoDBAPI
kclConfig *config.KinesisClientLibConfiguration kclConfig *config.KinesisClientLibConfiguration
Retries int Retries int
skipTableCheck bool
} }
func NewDynamoCheckpoint(kclConfig *config.KinesisClientLibConfiguration) *DynamoCheckpoint { func NewDynamoCheckpoint(kclConfig *config.KinesisClientLibConfiguration) *DynamoCheckpoint {
@ -103,7 +102,7 @@ func (checkpointer *DynamoCheckpoint) Init() error {
checkpointer.svc = dynamodb.New(s) checkpointer.svc = dynamodb.New(s)
} }
if !checkpointer.skipTableCheck && !checkpointer.doesTableExist() { if !checkpointer.doesTableExist() {
return checkpointer.createTable() return checkpointer.createTable()
} }
return nil return nil