Commit ca0c47f8 by amira

update commands

parent 836e0ee9
...@@ -5,7 +5,7 @@ ...@@ -5,7 +5,7 @@
3 copy the job jar to flink jobmanager instance and start it: 3 copy the job jar to flink jobmanager instance and start it:
$ JOBMANAGER_CONTAINER=$(docker ps --filter name=jobmanager --format={{.ID}}) $ JOBMANAGER_CONTAINER=$(docker ps --filter name=jobmanager --format={{.ID}})
$ docker cp path/to/jar "$JOBMANAGER_CONTAINER":/job.jar $ docker cp path/to/jar "$JOBMANAGER_CONTAINER":/job.jar
$ docker exec -t -i "$JOBMANAGER_CONTAINER" flink run /job.jar $ docker exec -it "$JOBMANAGER_CONTAINER" flink run /job.jar &
4 prey (;-) 4 prey (;-)
...@@ -25,3 +25,19 @@ curl -s http://localhost:8080/admin/v2/namespaces/mcx/publish ...@@ -25,3 +25,19 @@ curl -s http://localhost:8080/admin/v2/namespaces/mcx/publish
https://pulsar.apache.org/docs/latest/admin-api/overview/ https://pulsar.apache.org/docs/latest/admin-api/overview/
[performance test]
open 3 shells in the pulsar container:
- client shell:
./pulsar-perf simulation-controller --cluster local_pulsar --client-port 5000 --clients localhost
- controller shell:
./pulsar-perf simulation-client --port 5000 --service-url http://localhost:8080
// send commands:
- 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