Кассандра-стресс-тест смешанной нагрузки

Question

Кассандра-стресс-тест смешанной нагрузки

Нужна помощь в отношении стресс-тестов на кассандре. Я установил инструмент Cassandra-Stress 2.1 с веб-сайта datastax. Я хочу сделать чтение + запись стресс-тестирование в соотношении 10: 1 и с использованием 15 потоков. Я как-то не могу заставить его работать. Я могу успешно тестировать чтение и запись отдельно.

Я использую команду :./cassandra-stress смешанное отношение (запись =1, чтение =10) n=10000 cl=ONE -port thrift=9160 -schema keyspace="Keyspace1" -mode thrift smart -rate threads>=15 потоков \<=15 -узел 192.168.5.10

Хотя я указываю порт как 9160, но он использует собственный порт 9042.

Я получаю следующую ошибку:

    ERROR 18:03:07 Error creating pool to /192.168.5.11:9042
    com.datastax.driver.core.TransportException: [/192.168.5.11:9042] Cannot connect

    at com.datastax.driver.core.Connection.<init>(Connection.java:106) ~[cassandra-driver-core-2.1.2.jar:na]
    at com.datastax.driver.core.PooledConnection.<init>(PooledConnection.java:32) ~[cassandra-driver-core-2.1.2.jar:na]
    at com.datastax.driver.core.Connection$Factory.open(Connection.java:521) ~[cassandra-driver-core-2.1.2.jar:na]
    at com.datastax.driver.core.DynamicConnectionPool.<init>(DynamicConnectionPool.java:73) ~[cassandra-driver-core-2.1.2.jar:na]
    at com.datastax.driver.core.HostConnectionPool.newInstance(HostConnectionPool.java:33) ~[cassandra-driver-core-2.1.2.jar:na]
    at com.datastax.driver.core.SessionManager.replacePool(SessionManager.java:239) ~[cassandra-driver-core-2.1.2.jar:na]
    at com.datastax.driver.core.SessionManager.access$400(SessionManager.java:39) ~[cassandra-driver-core-2.1.2.jar:na]
    at com.datastax.driver.core.SessionManager$3.call(SessionManager.java:272) [cassandra-driver-core-2.1.2.jar:na]
    at com.datastax.driver.core.SessionManager$3.call(SessionManager.java:264) [cassandra-driver-core-2.1.2.jar:na]
    at java.util.concurrent.FutureTask.run(FutureTask.java:262) [na:1.7.0_72]
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) [na:1.7.0_72]
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) [na:1.7.0_72]
    at java.lang.Thread.run(Thread.java:745) [na:1.7.0_72]
    Caused by: org.jboss.netty.channel.ConnectTimeoutException: connection timed out: /192.168.5.11:9042
    at org.jboss.netty.channel.socket.nio.NioClientBoss.processConnectTimeout(NioClientBoss.java:137) ~[netty-3.9.0.Final.jar:na]
    at org.jboss.netty.channel.socket.nio.NioClientBoss.process(NioClientBoss.java:83) ~[netty-3.9.0.Final.jar:na]
    at org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:318) ~[netty-3.9.0.Final.jar:na]
    at org.jboss.netty.channel.socket.nio.NioClientBoss.run(NioClientBoss.java:42) ~[netty-3.9.0.Final.jar:na]
    ... 3 common frames omitted
    ERROR 18:03:12 Error creating pool to /192.168.5.13:9042
    com.datastax.driver.core.TransportException: [/192.168.5.13:9042] Cannot connect
    at com.datastax.driver.core.Connection.<init>(Connection.java:106) ~[cassandra-driver-core-2.1.2.jar:na]
    at com.datastax.driver.core.PooledConnection.<init>(PooledConnection.java:32) ~[cassandra-driver-core-2.1.2.jar:na]
    at com.datastax.driver.core.Connection$Factory.open(Connection.java:521) ~[cassandra-driver-core-2.1.2.jar:na]
    at com.datastax.driver.core.DynamicConnectionPool.<init>(DynamicConnectionPool.java:73) ~[cassandra-driver-core-2.1.2.jar:na]
    at com.datastax.driver.core.HostConnectionPool.newInstance(HostConnectionPool.java:33) ~[cassandra-driver-core-2.1.2.jar:na]
    at com.datastax.driver.core.SessionManager.replacePool(SessionManager.java:239) ~[cassandra-driver-core-2.1.2.jar:na]
    at com.datastax.driver.core.SessionManager.access$400(SessionManager.java:39) ~[cassandra-driver-core-2.1.2.jar:na]
    at com.datastax.driver.core.SessionManager$3.call(SessionManager.java:272) [cassandra-driver-core-2.1.2.jar:na]
    at com.datastax.driver.core.SessionManager$3.call(SessionManager.java:264) [cassandra-driver-core-2.1.2.jar:na]
    at java.util.concurrent.FutureTask.run(FutureTask.java:262) [na:1.7.0_72]
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) [na:1.7.0_72]
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) [na:1.7.0_72]
    at java.lang.Thread.run(Thread.java:745) [na:1.7.0_72]
    Caused by: org.jboss.netty.channel.ConnectTimeoutException: connection timed out: /192.168.5.13:9042
    at org.jboss.netty.channel.socket.nio.NioClientBoss.processConnectTimeout(NioClientBoss.java:137) ~[netty-3.9.0.Final.jar:na]
    at org.jboss.netty.channel.socket.nio.NioClientBoss.process(NioClientBoss.java:83) ~[netty-3.9.0.Final.jar:na]
    at org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:318) ~[netty-3.9.0.Final.jar:na]
    at
    org.jboss.netty.channel.socket.nio.NioClientBoss.run(NioClientBoss.java:42) ~[netty-3.9.0.Final.jar:na]
    ... 3 common frames omitted

0

cassandra nosql stress-testing thrift-protocol cassandra-stress

Источник

user311264 03 фев '15 в 05:21

1 ответ

Другие вопросы по тегам cassandra nosql stress-testing thrift-protocol cassandra-stress

user4304840 04 фев '15 в 17:02 2015-02-04 17:02 · Answer 1 · 2015-02-04 17:02

Вам нужно экранировать метасимволы оболочки (в данном случае это парантезы и угловые скобки). Попробуй это:

./cassandra-stress mixed ratio\(write=1,read=10\) n=10000 cl=ONE -port thrift=9160 -schema keyspace="Keyspace1" -mode thrift smart -rate threads\>=15 threads\<=15 -node 192.168.5.10

0

Источник

user4304840 04 фев '15 в 17:02