gistfile1.txt

# mv the folder to the cluster
cluster.connection.nodes.each {|n| n.scp('/tmp/mph/csp-2.0.80-plugin-notajar') }

# remove old plugin
Provision::ThreadPool.new(cluster.connection.nodes) do |node|
  node.ssh %Q{
    sudo plugin -r csp
  }
end

# NOTE update this plugin line but use sudo
Provision::ThreadPool.new(cluster.connection.nodes) do |node|
  node.ssh %Q{
    sudo plugin -i csp -u file:///tmp/csp-2.0.80-plugin-notajar
  }
end

Provision::Core::ElasticsearchRequest.post(cluster, '_flush')
 
cluster.connection.nodes.each do |node|
  Provision::Core::ShardAllocationHalter.new(cluster) do
    node.ssh('sudo service elasticsearch restart')
    Provision::Core::ShardRecoveryVerifier.new(cluster).verify
  end
  Provision::Core::ShardRecoveryVerifier.new(cluster).verify
end