Cluster: fix redis-trib reference of variable in warning.
This commit is contained in:
parent
32a1a089df
commit
2dd330e7bc
@ -937,7 +937,7 @@ class RedisTrib
|
|||||||
source.r.client.call(["migrate",target.info[:host],target.info[:port],"",0,@timeout,:keys,*keys])
|
source.r.client.call(["migrate",target.info[:host],target.info[:port],"",0,@timeout,:keys,*keys])
|
||||||
rescue => e
|
rescue => e
|
||||||
if o[:fix] && e.to_s =~ /BUSYKEY/
|
if o[:fix] && e.to_s =~ /BUSYKEY/
|
||||||
xputs "*** Target key #{key} exists. Replacing it for FIX."
|
xputs "*** Target key exists. Replacing it for FIX."
|
||||||
source.r.client.call(["migrate",target.info[:host],target.info[:port],"",0,@timeout,:replace,:keys,*keys])
|
source.r.client.call(["migrate",target.info[:host],target.info[:port],"",0,@timeout,:replace,:keys,*keys])
|
||||||
else
|
else
|
||||||
puts ""
|
puts ""
|
||||||
|
Loading…
x
Reference in New Issue
Block a user