From 4f79203f44d2979a8151d77e55e22d7e497af624 Mon Sep 17 00:00:00 2001 From: Tao Jiang Date: Thu, 3 Oct 2019 20:45:34 -0500 Subject: [PATCH] Get rid of unused skipTableCheck (#39) --- clientlibrary/checkpoint/dynamodb-checkpointer.go | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/clientlibrary/checkpoint/dynamodb-checkpointer.go b/clientlibrary/checkpoint/dynamodb-checkpointer.go index e80c6c0..684d0cc 100644 --- a/clientlibrary/checkpoint/dynamodb-checkpointer.go +++ b/clientlibrary/checkpoint/dynamodb-checkpointer.go @@ -61,7 +61,6 @@ type DynamoCheckpoint struct { svc dynamodbiface.DynamoDBAPI kclConfig *config.KinesisClientLibConfiguration Retries int - skipTableCheck bool } func NewDynamoCheckpoint(kclConfig *config.KinesisClientLibConfiguration) *DynamoCheckpoint { @@ -103,7 +102,7 @@ func (checkpointer *DynamoCheckpoint) Init() error { checkpointer.svc = dynamodb.New(s) } - if !checkpointer.skipTableCheck && !checkpointer.doesTableExist() { + if !checkpointer.doesTableExist() { return checkpointer.createTable() } return nil