diff options
Diffstat (limited to 'weed/replication/replicator.go')
| -rw-r--r-- | weed/replication/replicator.go | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/weed/replication/replicator.go b/weed/replication/replicator.go index 1ed60f536..051199adb 100644 --- a/weed/replication/replicator.go +++ b/weed/replication/replicator.go @@ -31,6 +31,9 @@ func NewReplicator(sourceConfig util.Configuration, configPrefix string, dataSin } func (r *Replicator) Replicate(ctx context.Context, key string, message *filer_pb.EventNotification) error { + if message.IsFromOtherCluster && r.sink.GetName() == "filer" { + return nil + } if !strings.HasPrefix(key, r.source.Dir) { glog.V(4).Infof("skipping %v outside of %v", key, r.source.Dir) return nil |