pscp -h slaves -O StrictHostKeyChecking=no src /users/szhong

pssh -i -h slaves -O StrictHostKeyChecking=no cmd

kubectl delete daemonsets,replicasets,services,deployments,pods,rc --all --grace-period=0 --force

heron kill kubernetes WindowedWordCountTopology

kubectl proxy -p 8001

helm init

kubectl create serviceaccount tiller \
--namespace kube-system \

kubectl create clusterrolebinding tiller-cluster-rule \
--clusterrole cluster-admin \
--serviceaccount kube-system:tiller

kubectl patch deploy tiller-deploy \
--namespace kube-system \
--patch '{"spec":{"template":{"spec":{"serviceAccount":"tiller"}}}}'

helm package helm/flink/
helm install --name flink --set flink.num_taskmanagers=5 flink*.tgz

helm install --name spark stable/spark

helm repo add incubator http://storage.googleapis.com/kubernetes-charts-incubator
helm install --name my-kafka incubator/kafka

helm repo add heron-charts https://storage.googleapis.com/heron-charts

helm install heron-charts/heron \
--set platform=gke \
--name kubernetes \
--values https://raw.githubusercontent.com/apache/incubator-heron/master/deploy/kubernetes/gke/small.yaml

heron config kubernetes \
set service_url http://localhost:8001/api/v1/namespaces/default/services/kubernetes-apiserver:9000/proxy

heron submit kubernetes \
~/.heron/examples/heron-streamlet-examples.jar \
com.twitter.heron.examples.streamlet.WindowedWordCountTopology \
wwc

heron submit kubernetes ~/.heron/examples/heron-api-examples.jar \
com.twitter.heron.examples.api.AckingTopology acking