I certainly understand I could leverage the-ever-powerful NoSQLBench against an Astra DB, but would be interested in knowing if anyone has done hacking to figure out how to run cassandra-stress
against an Astra DB. Just tried to extract the secure connect bundle and perform something similar to below,
$ dse-6.8.7/resources/cassandra/tools/bin/cassandra-stress \ write n=1000000 cl=LOCAL_QUORUM -rate threads=100 -mode native cql3 \ user=astra password=CHANGE_ME \ -node 19d85d62-2c12-485a-82ef-7156b03c525f-us-east1.db.astra.datastax.com \ -schema "replication(strategy=NetworkTopologyStrategy, dc-1=1) compression=LZ4Compressor keyspace=astra" \ -transport "truststore=/home/mkadmin/astra-scb/trustStore.jks truststore-password=CHANGE_ME keystore=/home/mkadmin/astra-scb/identity.jks keystore-password=CHANGE_ME" -port "native=31906"
but it would only give me the following,
******************** Stress Settings ******************** Command: Type: write Count: 1,000,000 No Warmup: false Consistency Level: LOCAL_QUORUM Target Uncertainty: not applicable Key Size (bytes): 10 Counter Increment Distibution: add=fixed(1) ... Mode: API: JAVA_DRIVER_NATIVE Connection Style: CQL_PREPARED CQL Version: CQL3 Protocol Version: DSE_V2 Username: astra Password: *suppressed* Auth Provide Class: null Max Pending Per Connection: 128 Connections Per Host: 8 Compression: NONE Node: ... Schema: Keyspace: astra Replication Strategy: org.apache.cassandra.locator.NetworkTopologyStrategy Replication Strategy Options: {dc-1=1} Table Compression: LZ4Compressor Table Compaction Strategy: null Table Compaction Strategy Options: {} Transport: ... java.lang.RuntimeException: com.datastax.driver.core.exceptions.NoHostAvailableException: All host(s) tried for query failed (tried: 19d85d62-2c12-485a-82ef-7156b03c525f-us-east1.db.astra.datastax.com/34.73.23.96:30704 (com.datastax.driver.core.exceptions.TransportException: [19d85d62-2c12-485a-82ef-7156b03c525f-us-east1.db.astra.datastax.com/34.73.23.96:30704] Error writing), 19d85d62-2c12-485a-82ef-7156b03c525f-us-east1.db.astra.datastax.com/35.237.246.231:30704 (com.datastax.driver.core.exceptions.TransportException: [19d85d62-2c12-485a-82ef-7156b03c525f-us-east1.db.astra.datastax.com/35.237.246.231:30704] Error writing), 19d85d62-2c12-485a-82ef-7156b03c525f-us-east1.db.astra.datastax.com/34.75.56.197:30704 (com.datastax.driver.core.exceptions.TransportException: [19d85d62-2c12-485a-82ef-7156b03c525f-us-east1.db.astra.datastax.com/34.75.56.197:30704] Error writing)) at org.apache.cassandra.stress.settings.StressSettings.getJavaDriverClient(StressSettings.java:148) at org.apache.cassandra.stress.settings.StressSettings.getJavaDriverClient(StressSettings.java:116) at org.apache.cassandra.stress.settings.SettingsSchema.createKeySpaces(SettingsSchema.java:66) at org.apache.cassandra.stress.settings.StressSettings.maybeCreateKeyspaces(StressSettings.java:156) at org.apache.cassandra.stress.StressAction.run(StressAction.java:57) at org.apache.cassandra.stress.Stress.run(Stress.java:148) at org.apache.cassandra.stress.Stress.main(Stress.java:67) Caused by: com.datastax.driver.core.exceptions.NoHostAvailableException: All host(s) tried for query failed (tried: 19d85d62-2c12-485a-82ef-7156b03c525f-us-east1.db.astra.datastax.com/34.73.23.96:30704 (com.datastax.driver.core.exceptions.TransportException: [19d85d62-2c12-485a-82ef-7156b03c525f-us-east1.db.astra.datastax.com/34.73.23.96:30704] Error writing), 19d85d62-2c12-485a-82ef-7156b03c525f-us-east1.db.astra.datastax.com/35.237.246.231:30704 (com.datastax.driver.core.exceptions.TransportException: [19d85d62-2c12-485a-82ef-7156b03c525f-us-east1.db.astra.datastax.com/35.237.246.231:30704] Error writing), 19d85d62-2c12-485a-82ef-7156b03c525f-us-east1.db.astra.datastax.com/34.75.56.197:30704 (com.datastax.driver.core.exceptions.TransportException: [19d85d62-2c12-485a-82ef-7156b03c525f-us-east1.db.astra.datastax.com/34.75.56.197:30704] Error writing)) at com.datastax.driver.core.ControlConnection.reconnectInternal(ControlConnection.java:259) at com.datastax.driver.core.ControlConnection.connect(ControlConnection.java:98) at com.datastax.driver.core.Cluster$Manager.negotiateProtocolVersionAndConnect(Cluster.java:1926) at com.datastax.driver.core.Cluster$Manager.init(Cluster.java:1839) at com.datastax.driver.core.Cluster.getMetadata(Cluster.java:475) at org.apache.cassandra.stress.util.JavaDriverClient.connect(JavaDriverClient.java:180) at org.apache.cassandra.stress.settings.StressSettings.getJavaDriverClient(StressSettings.java:139) ... 6 more