diff --git a/store/v2/command_factory.go b/store/v2/command_factory.go index 8332891d6..77263b8d7 100644 --- a/store/v2/command_factory.go +++ b/store/v2/command_factory.go @@ -73,5 +73,7 @@ func (f *CommandFactory) CreateCompareAndSwapCommand(key string, value string, p } func (f *CommandFactory) CreateSyncCommand(now time.Time) raft.Command { - return &SyncCommand{time.Now()} + return &SyncCommand{ + Time: time.Now(), + } } diff --git a/store/v2/sync_command.go b/store/v2/sync_command.go index 4b6459079..caf2c37cc 100644 --- a/store/v2/sync_command.go +++ b/store/v2/sync_command.go @@ -21,7 +21,6 @@ func (c SyncCommand) CommandName() string { } func (c SyncCommand) Apply(server raft.Server) (interface{}, error) { - s, _ := server.StateMachine().(store.Store) s.DeleteExpiredKeys(c.Time)