Skip to content

Conversation

@anfeng
Copy link

@anfeng anfeng commented May 30, 2013

I have ported clj based messaging benchmark to Java. Currently, the benchmark code execute both Netty and ZMQ implementations.

@anfeng
Copy link
Author

anfeng commented May 30, 2013

localhost:storm-benchmark afeng$ lein test

lein test storm.benchmark.messaging-benchmark-test
179 [main] INFO backtype.storm.messaging.TransportFactory - Storm peer transport plugin:backtype.storm.messaging.netty.Context
(Netty) 1000 messages of payload size 102400 sent one by one
Total execution time: 10238ms
(Netty) 100000 short msgs in batches
Total execution time: 194ms

10830 [main] INFO backtype.storm.messaging.TransportFactory - Storm peer transport plugin:backtype.storm.messaging.zmq
(ZMQ) 1000 messages of payload size 102400 sent one by one
Total execution time: 11155ms
(ZMQ) 100000 short msgs in batches
Total execution time: 4403ms

Ran 1 tests containing 0 assertions.
0 failures, 0 errors.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant