diff options
Diffstat (limited to 'weed/replication/replicator.go')
| -rw-r--r-- | weed/replication/replicator.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/replication/replicator.go b/weed/replication/replicator.go index 66d194128..3e4bccc10 100644 --- a/weed/replication/replicator.go +++ b/weed/replication/replicator.go @@ -43,7 +43,7 @@ func (r *Replicator) Replicate(key string, message *filer_pb.EventNotification) if !strings.HasPrefix(key, r.source.Dir) { return nil } - key = r.sink.GetDirectory() + key[len(r.source.Dir):] + key = r.sink.GetSinkToDirectory() + key[len(r.source.Dir):] if message.OldEntry != nil && message.NewEntry == nil { return r.sink.DeleteEntry(key, message.OldEntry, message.DeleteChunks) } |