netflix / cassjmeter Goto Github PK

Thanks!

Hi,
I am getting following exception when i am trying to run the Jmeter for put operation,
ERROR: java.lang.RuntimeException: java.lang.IllegalArgumentException: No enum constant com.netflix.astyanax.model.ConsistencyLevel.CL_ONE
com.netflix.jmeter.connections.a6x.AstyanaxConnection.keyspace(AstyanaxConnection.java:100)
com.netflix.jmeter.connections.a6x.AstyanaxOperation.put(AstyanaxOperation.java:72)
com.netflix.jmeter.sampler.PutSampler.execute(PutSampler.java:14)
com.netflix.jmeter.sampler.AbstractSampler.sample(AbstractSampler.java:205)
org.apache.jmeter.threads.JMeterThread.process_sampler(JMeterThread.java:428)
org.apache.jmeter.threads.JMeterThread.run(JMeterThread.java:256)
java.lang.Thread.run(Unknown Source)

I want to know that will this support CQL also?
Thanks,
Justin Joseph

Hi,
I'm running JMeter 2.10. I installed the latest version of CassJMeter but having problem connecting to my Cassandra DB. I'm getting ConnectException below. Any pointer would be much appreciated.

What other ways do people use to connect Cassandra from JMeter?

In the CassandraProperties config entry, I have the following:

cassandraServers: :9160
clientType:com.netflix.jmeter.connections.thrift.ThriftConnection
clusterName:Test Cluster
keyspace:
maxConnsPerHost:100
readConsistency:ONE

ERROR: java.lang.RuntimeException: org.apache.thrift.transport.TTransportException: java.net.ConnectException: Connection refused
com.netflix.jmeter.utils.CClient.getClient(CClient.java:33)
com.netflix.jmeter.connections.thrift.ThriftConnection$1.initialValue(ThriftConnection.java:24)
com.netflix.jmeter.connections.thrift.ThriftConnection$1.initialValue(ThriftConnection.java:18)
java.lang.ThreadLocal.setInitialValue(ThreadLocal.java:160)
java.lang.ThreadLocal.get(ThreadLocal.java:150)
com.netflix.jmeter.connections.thrift.ThriftConnection.newOperation(ThriftConnection.java:40)
com.netflix.jmeter.sampler.GetSampler.execute(GetSampler.java:9)
com.netflix.jmeter.sampler.AbstractSampler.sample(AbstractSampler.java:205)
org.apache.jmeter.threads.JMeterThread.process_sampler(JMeterThread.java:429)
org.apache.jmeter.threads.JMeterThread.run(JMeterThread.java:257)
java.lang.Thread.run(Thread.java:744)

Thanks,
-Jeffrey

When trying to Get a record using the "Cassandra Get" sampler, the following error is returned: "ERROR: com.netflix.jmeter.sampler.OperationException: com.netflix.astyanax.connectionpool.exceptions.BadRequestException: BadRequestException: [host=removed for privacy, latency=41(41), attempts=1] InvalidRequestException(why:Not enough bytes to read value of component 0)
com.netflix.jmeter.connections.a6x.AstyanaxOperation.get(AstyanaxOperation.java:163)
com.netflix.jmeter.sampler.GetSampler.execute(GetSampler.java:11)
com.netflix.jmeter.sampler.AbstractSampler.sample(AbstractSampler.java:205)
org.apache.jmeter.threads.JMeterThread.process_sampler(JMeterThread.java:426)
org.apache.jmeter.threads.JMeterThread.run(JMeterThread.java:255)
java.lang.Thread.run(Thread.java:722)

The column family I am trying to read from has a composite primary key that uses three columns where the column data type for the key are int, timestamp, int.

If I try to use the Cassandra Composite Get, it returns a null pointer exception.

I am trying out this plugin to test the response on GET.
SO, i added the Cassandra GET to my thread group(i have the properties set as well) and in the Row key and Column name i have the following values-
Row Key: ${__Random(1,1000)}
Column Name: {__Random(0,5)}

When i run this, i don't see any Response data but if i change the values to actual row key and column name, it works.
Could someone help me figure out why Random is not working?

mvn install fails at this stage

jijojv:$ mvn dependency:copy-dependencies install -DexcludeGroupIds=org.apache.jmeter
...
Downloading: http://oss.sonatype.org/content/groups/sourceforge//org/sonatype/oss/oss-parent/3/oss-parent-3.pom
178b downloaded  (oss-parent-3.pom)
[WARNING] *** CHECKSUM FAILED - Checksum failed on download: local = '81ffbd1712afe8cdf138b570c0fc9934742c33c1'; remote = '<html>
<head><title>301' - RETRYING
Downloading: http://oss.sonatype.org/content/groups/sourceforge//org/sonatype/oss/oss-parent/3/oss-parent-3.pom
178b downloaded  (oss-parent-3.pom)
[WARNING] *** CHECKSUM FAILED - Checksum failed on download: local = '81ffbd1712afe8cdf138b570c0fc9934742c33c1'; remote = '<html>
<head><title>301' - IGNORING
[INFO] ------------------------------------------------------------------------
[ERROR] BUILD ERROR
[INFO] ------------------------------------------------------------------------
[INFO] Error building POM (may not be this project's POM).

After lots of googling i figured out a workaround.

jijojv:$  rm -rf ~/.m2/repository/org/sonatype
jijojv:$  cat > ~/.m2/settings.xml <<DONE
<settings xmlns="http://maven.apache.org/SETTINGS/1.0.0"
      xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
      xsi:schemaLocation="http://maven.apache.org/SETTINGS/1.0.0
                          http://maven.apache.org/xsd/settings-1.0.0.xsd">
  <mirrors>
    <mirror>
      <id>HTTPSsourceforge</id>
      <name>HTTPSsourceforge</name>
      <url>https://oss.sonatype.org/content/groups/public/</url>
      <mirrorOf>sourceforge</mirrorOf>
    </mirror>
  </mirrors>
</settings>
DONE

jijojv:$  mvn dependency:copy-dependencies install -DexcludeGroupIds=org.apache.jmeter

I am trying to insert data into cassandra table using jmeter with cassandra put sampler.This is my table schema in cassandra crated by cql-3 .

CREATE TABLE sensor3 (
sensor_id int,
time timestamp,
sensor_value text,
PRIMARY KEY (sensor_id, time)
) WITH COMPACT STORAGE AND
bloom_filter_fp_chance=0.010000 AND
caching='KEYS_ONLY' AND
comment='' AND
dclocal_read_repair_chance=0.000000 AND
gc_grace_seconds=864000 AND
read_repair_chance=0.100000 AND
replicate_on_write='true' AND
populate_io_cache_on_flush='false' AND
compaction={'class': 'SizeTieredCompactionStrategy'} AND
compression={'sstable_compression': 'SnappyCompressor'};

While using cassandra put sampler i define the following inputs.

Client Type : com.netflix.jmeter.connections.a6x.AstyanaxConnection

i have tried two ways to do the same but find different errors.

1. In First case i have used the Inbuilt time function to get the current timstamp which is below

Cassandra Put Properties --

Column family : sensor3
Row Key : 1
Column Name : ${__time(yyyyMMdd-HHmmss,YMDHMS)}
Column value : ${__Random(1,1000)}
Column Serializer : DateSerializer
Value Serializer : StringSerializer
Key Serializer : IntegerSerialzer

Attaching Stack trace of problem :

ERROR: java.lang.IllegalArgumentException
java.util.Date.parse(Date.java:615)
com.netflix.jmeter.sampler.AbstractSampler.convert(AbstractSampler.java:88)
com.netflix.jmeter.sampler.AbstractSampler.getColumnName(AbstractSampler.java:130)
com.netflix.jmeter.sampler.PutSampler.execute(PutSampler.java:14)
com.netflix.jmeter.sampler.AbstractSampler.sample(AbstractSampler.java:205)
org.apache.jmeter.threads.JMeterThread.process_sampler(JMeterThread.java:428)
org.apache.jmeter.threads.JMeterThread.run(JMeterThread.java:256)
java.lang.Thread.run(Thread.java:679)

2. Second Case tried the Hard coded value of Date Object and got the error

Cassandra Put Properties --

Column family : sensor3
Row Key : 1
Column Name : Sat, 12 Aug 1995 13:30:00 GMT
Column value : ${__Random(1,1000)}
Column Serializer : DateSerializer
Value Serializer : StringSerializer
Key Serializer : IntegerSerialzer

Attaching Stack trace of problem :

ERROR: java.lang.IllegalArgumentException
java.util.Date.parse(Date.java:615)
com.netflix.jmeter.sampler.AbstractSampler.convert(AbstractSampler.java:88)
com.netflix.jmeter.sampler.AbstractSampler.getColumnName(AbstractSampler.java:130)
com.netflix.jmeter.sampler.PutSampler.execute(PutSampler.java:14)
com.netflix.jmeter.sampler.AbstractSampler.sample(AbstractSampler.java:205)
org.apache.jmeter.threads.JMeterThread.process_sampler(JMeterThread.java:428)
org.apache.jmeter.threads.JMeterThread.run(JMeterThread.java:256)
java.lang.Thread.run(Thread.java:679)

please tell me ,What i'm doing wrong or is there other way to do the same ?

https://github.com/Netflix/CassJMeter/blob/master/src/main/java/com/netflix/jmeter/sampler/Connection.java#L52

this line asserts that there are no servers configured! also, the method assumes the port to use for all the servers is the port configures in the last server defined.

Hi I want to implement a new function(implement a zipf generator like the one in YCSB) instead of __Random. but I am not sure where I could find the point to implement new function in cassJmeter. Could anyone do me a huge favor and help me to do that.

Hello,

Can any one give the Cassandra driver for Jmeter which will support Cassandra 3.1.

I see this error in jmeter.log when trying to start a test with CassGet.
I'm using jmeter-2.9, java version "1.7.0_25" and Mac OS X (the same error I saw on Linux).

Test failed! java.lang.NoClassDefFoundError: Could not initialize class com.netflix.jmeter.connections.thrift.ThriftConnection

I'm assuming this page is spam? I don't find it especially helpful for using the plugin.

Hi,

I want to use this plugin to test Cassandra 2.2 using native transport. Is there a way to use this with DataStax native driver (neither A6x nor thrift but native CQL binary protocol) with this plugin? My schema uses collection types and I don't see serializers for collections. By any chance would bytes serializers work?

Thanks

This is not compatible with ApacheJmeter3.3 giving the following error when starting Jmeter
ERROR o.a.j.JMeter: Uncaught exception:
java.lang.NoClassDefFoundError: Could not initialize class org.apache.jmeter.gui.util.MenuFactory
at org.apache.jmeter.control.gui.TestPlanGui.createPopupMenu(TestPlanGui.java:93) ~[ApacheJMeter_core.jar:3.3 r1808647]

Can someone send me the jars for cassandra jmeter liek connection , put update and delete. The more plugins the better on [email protected]

Error 👍
ERROR o.a.j.JMeter: Uncaught exception:
java.lang.NoClassDefFoundError: org/apache/cassandra/utils/FBUtilities

I see this error in jmeter.log when trying to start a test with CassGet. I'm using jmeter-3.0, java version "1.8.0_111" and windows machine .