Retention policy and database were reversed in log

pull/1562/head
Philip O'Toole 2015-02-11 10:11:09 -08:00
parent 0c8ded4197
commit 19cd5509c0
1 changed files with 1 additions and 1 deletions

View File

@ -325,7 +325,7 @@ func (s *Server) EnforceRetentionPolicies() {
for _, g := range rp.shardGroups {
if g.EndTime.Add(rp.Duration).Before(time.Now()) {
log.Printf("shard group %d, retention policy %s, database %s due for deletion",
g.ID, db.name, rp.Name)
g.ID, rp.Name, db.name)
if err := s.DeleteShardGroup(db.name, rp.Name, g.ID); err != nil {
log.Printf("failed to request deletion of shard group %d: %s", g.ID, err.Error())
}