Commit 3e1494d8 by Amir Aharon

add ons

parent 713d9dfb
......@@ -5,7 +5,7 @@
3 copy the job jar to flink jobmanager instance and start it:
$ JOBMANAGER_CONTAINER=$(docker ps --filter name=jobmanager --format={{.ID}})
$ docker cp path/to/jar "$JOBMANAGER_CONTAINER":/job.jar
$ docker exec -it "$JOBMANAGER_CONTAINER" flink run /job.jar &
$ docker exec -d "$JOBMANAGER_CONTAINER" flink run /job.jar &
4 prey (;-)
......@@ -33,10 +33,11 @@ open 3 shells in the pulsar container:
- controller shell:
./pulsar-perf simulation-controller --cluster local_pulsar --client-port 5000 --clients localhost
* pay attention to the cluster name
// ./pulsar-perf simulation-controller --cluster pulsar-cluster-1 --client-port 5000 --clients localhost
// send commands:
trade mcx activities activity --rate 1000 --size 1000
stop mcx activities activity
trade mcx public activity --rate 1000 --size 1000
stop mcx public activity
- monitor shell:
./pulsar-perf monitor-brokers --connect-string zookeeper:2181
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or sign in to comment