Skip to content

Instantly share code, notes, and snippets.

View joshmyers's full-sized avatar

Josh Myers joshmyers

View GitHub Profile
./nodetool upgradesstables
Exception in thread "main" java.lang.reflect.UndeclaredThrowableException
at com.sun.proxy.$Proxy0.upgradeSSTables(Unknown Source)
at org.apache.cassandra.tools.NodeProbe.upgradeSSTables(NodeProbe.java:193)
at org.apache.cassandra.tools.NodeCmd.optionalKSandCFs(NodeCmd.java:1071)
at org.apache.cassandra.tools.NodeCmd.main(NodeCmd.java:838)
Caused by: javax.management.ReflectionException: Signature mismatch for operation upgradeSSTables: (java.lang.String, [Ljava.lang.String;) should be (java.lang.String, boolean, [Ljava.lang.String;)
at com.sun.jmx.mbeanserver.PerInterface.noSuchMethod(PerInterface.java:170)
at com.sun.jmx.mbeanserver.PerInterface.invoke(PerInterface.java:135)
at com.sun.jmx.mbeanserver.MBeanSupport.invoke(MBeanSupport.java:252)
Service exit with a return value of 3
java.lang.ClassNotFoundException: org.apache.cassandra.thrift.CassandraDaemon
at java.net.URLClassLoader$1.run(URLClassLoader.java:366)
at java.net.URLClassLoader$1.run(URLClassLoader.java:355)
at java.security.AccessController.doPrivileged(Native Method)
at java.net.URLClassLoader.findClass(URLClassLoader.java:354)
at java.lang.ClassLoader.loadClass(ClassLoader.java:425)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:308)
at java.lang.ClassLoader.loadClass(ClassLoader.java:358)
at org.apache.commons.daemon.support.DaemonLoader.load(DaemonLoader.java:151)
```ruby
2 node C* cluster, devcass1 and devcass2.
[1] pry(main)> Cassandra.VERSION
=> "1.1"
[2] pry(main)* devcass_client = Cassandra.new('mydrive_development', [ 'devcass1:9160', 'devcass2:9160'], :retries => 2, :connect_timeout => 5)
=> #<Cassandra:46422280, @keyspace="mydrive_development", @schema={}, @servers=["devcass1:9160", "devcass2:9160"]>
[3] pry(main)> devcass_client.get(:Users, 'key')
=> {"foo"=>"bar"}
## Sources ###################################################
agent.sources = http syslogudp
agent.sources.http.type = http
agent.sources.http.bind = 0.0.0.0
agent.sources.http.port = 4444
agent.sources.http.channels = default_s3_channel
## Interceptors #################################################
agent.sources.http.interceptors = itime ihost
agent.sinks.confused_s3_aggregate_profile_sink1.type = hdfs
agent.sinks.confused_s3_aggregate_profile_sink1.channel = confused_s3_aggregate_profile_channel
agent.sinks.confused_s3_aggregate_profile_sink1.hdfs.path = s3n://mydrive-confused-reports/driver-profiles/%Y-%m-%d
agent.sinks.confused_s3_aggregate_profile_sink1.hdfs.fileType = DataStream
agent.sinks.confused_s3_aggregate_profile_sink1.hdfs.batchSize = 5
agent.sinks.confused_s3_aggregate_profile_sink1.hdfs.writeFormat = Text
agent.sinks.confused_s3_aggregate_profile_sink1.serializer = com.mydrivesolutions.flume.serialization.HeaderAndBodyTextEventSerializer$Builder
agent.sinks.confused_s3_aggregate_profile_sink1.serializer.columns = log_type reporting_bucket subscription_id
agent.sinks.confused_s3_aggregate_profile_sink1.serializer.format = DriverProfile
agent.sinks.confused_s3_aggregate_profile_sink1.serializer.delimiter =
agent.sinks.cappucino_s3_aggregate_profile_sink1.type = hdfs
agent.sinks.cappucino_s3_aggregate_profile_sink1.channel =
cappucino_s3_aggregate_profile_channel
agent.sinks.cappucino_s3_aggregate_profile_sink1.hdfs.path =
s3n://mydrive-cappucino-reports/driver-profiles/%Y-%m-%d
agent.sinks.cappucino_s3_aggregate_profile_sink1.hdfs.fileType = DataStream
agent.sinks.cappucino_s3_aggregate_profile_sink1.hdfs.writeFormat = Text
agent.sinks.cappucino_s3_aggregate_profile_sink1.serializer =
com.mydrivesolutions.flume.serialization.HeaderAndBodyTextEventSerializer$Builder
agent.sinks.cappucino_s3_aggregate_profile_sink1.serializer.columns =
servers = Array.new
cassandra_nodes.each do |cass_node|
servers << { "name" : "#{cass_node}", "port": "#{['jmxtrans']['jmx_port']}", "type": "jmx" }
end
[
{
"name": "dev",
"columnFamilies": [
{
"name": "AggregateProfiles"
},
{
"name": "LinkHistory"
},
~ $ cassandra-cli
Connected to: "Test Cluster" on 127.0.0.1/9160
Welcome to Cassandra CLI version 1.2.6
Type 'help;' or '?' for help.
Type 'quit;' or 'exit;' to quit.
[default@unknown] use cassandra_test;
Authenticated to keyspace: cassandra_test
[default@mydrive_test] update column family TripProfiles
root@measuring1:/opt/graphite/storage/whisper# whisper-info.py stats/dev/apps/deployments/test.wsp
maxRetention: 31536000
xFilesFactor: 0.0
aggregationMethod: sum
fileSize: 378432028
Archive 0
retention: 31536000
secondsPerPoint: 1
points: 31536000