aboutsummaryrefslogtreecommitdiff
path: root/weed/command/filer_replication.go
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2018-09-17 01:37:24 -0700
committerChris Lu <chris.lu@gmail.com>2018-09-17 01:37:24 -0700
commit779641e9d4d9f843267d0c44f9fc5f2c201462d3 (patch)
tree0090dee4f3f40db8f0470725ff74982119e88216 /weed/command/filer_replication.go
parentb7a375f5aab78ef9a04c456ad0c46d9a5652eb88 (diff)
downloadseaweedfs-779641e9d4d9f843267d0c44f9fc5f2c201462d3.tar.xz
seaweedfs-779641e9d4d9f843267d0c44f9fc5f2c201462d3.zip
adjust replicated entry name
Diffstat (limited to 'weed/command/filer_replication.go')
-rw-r--r--weed/command/filer_replication.go2
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/command/filer_replication.go b/weed/command/filer_replication.go
index 18f549edc..25bca7c97 100644
--- a/weed/command/filer_replication.go
+++ b/weed/command/filer_replication.go
@@ -44,7 +44,7 @@ func runFilerReplicate(cmd *Command, args []string) bool {
}
}
- replicator := replication.NewReplicator(config.Sub("sink.filer"))
+ replicator := replication.NewReplicator(config.Sub("source.filer"), config.Sub("sink.filer"))
for {
key, m, err := notificationInput.ReceiveMessage()