David McNelis dmcnelis
dmcnelis
/ gist:6164466
Created
August 6, 2013 13:36
System hints stuck at 99.75% complete on multiple nodes
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| DEBUG 09:35:05,207 Thrift transport error occurred during processing of message. | |
| org.apache.thrift.transport.TTransportException | |
| at org.apache.thrift.transport.TIOStreamTransport.read(TIOStreamTransport.java:132) | |
| at org.apache.thrift.transport.TTransport.readAll(TTransport.java:84) | |
| at org.apache.thrift.transport.TFramedTransport.readFrame(TFramedTransport.java:129) | |
| at org.apache.thrift.transport.TFramedTransport.read(TFramedTransport.java:101) | |
| at org.apache.thrift.transport.TTransport.readAll(TTransport.java:84) | |
| at org.apache.thrift.protocol.TBinaryProtocol.readAll(TBinaryProtocol.java:378) | |
| at org.apache.thrift.protocol.TBinaryProtocol.readI32(TBinaryProtocol.java:297) | |
| at org.apache.thrift.protocol.TBinaryProtocol.readMessageBegin(TBinaryProtocol.java:204) |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| DEBUG [Thrift:10] 2013-08-02 13:27:24,344 CustomTThreadPoolServer.java (line 209) Thrift transport error occurred during processing of message. | |
| org.apache.thrift.transport.TTransportException | |
| at org.apache.thrift.transport.TIOStreamTransport.read(TIOStreamTransport.java:132) | |
| at org.apache.thrift.transport.TTransport.readAll(TTransport.java:84) | |
| at org.apache.thrift.transport.TFramedTransport.readFrame(TFramedTransport.java:129) | |
| at org.apache.thrift.transport.TFramedTransport.read(TFramedTransport.java:101) | |
| at org.apache.thrift.transport.TTransport.readAll(TTransport.java:84) | |
| at org.apache.thrift.protocol.TBinaryProtocol.readAll(TBinaryProtocol.java:378) | |
| at org.apache.thrift.protocol.TBinaryProtocol.readI32(TBinaryProtocol.java:297) | |
| at org.apache.thrift.protocol.TBinaryProtocol.readMessageBegin(TBinaryProtocol.java:204) |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| java.lang.AssertionError: [min(-1),max(-9124270273076175621)] | |
| at org.apache.cassandra.dht.Bounds.<init>(Bounds.java:41) | |
| at org.apache.cassandra.dht.Bounds.<init>(Bounds.java:34) | |
| at org.apache.cassandra.dht.Bounds.withNewRight(Bounds.java:121) | |
| at org.apache.cassandra.service.StorageProxy.getRangeSlice(StorageProxy.java:1172) | |
| at org.apache.cassandra.cql3.statements.SelectStatement.execute(SelectStatement.java:124) | |
| at org.apache.cassandra.cql3.statements.SelectStatement.execute(SelectStatement.java:56) | |
| at org.apache.cassandra.cql3.QueryProcessor.processStatement(QueryProcessor.java:132) | |
| at org.apache.cassandra.cql3.QueryProcessor.process(QueryProcessor.java:143) | |
| at org.apache.cassandra.thrift.CassandraServer.execute_cql3_query(CassandraServer.java:1707) |
dmcnelis
/ TableWriter.java
Last active
December 16, 2015 11:08
SSTables and CQL3 in Cassandra 1.2.3
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| package com.emergingthreats.massif.etl; | |
| import java.io.File; | |
| import java.io.IOException; | |
| import java.nio.ByteBuffer; | |
| import org.apache.cassandra.db.marshal.AsciiType; | |
| import org.apache.cassandra.dht.Murmur3Partitioner; | |
| import org.apache.cassandra.io.sstable.SSTableSimpleUnsortedWriter; |
dmcnelis
/ gist:5405832
Created
April 17, 2013 16:42
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| ERROR 07:42:01,714 Exception in thread Thread[Thrift:26,5,main] | |
| java.lang.AssertionError: [min(-1),max(-219851097003960625)] | |
| at org.apache.cassandra.dht.Bounds.<init>(Bounds.java:41) | |
| at org.apache.cassandra.dht.Bounds.<init>(Bounds.java:34) | |
| at org.apache.cassandra.dht.Bounds.withNewRight(Bounds.java:121) | |
| at org.apache.cassandra.service.StorageProxy.getRangeSlice(StorageProxy.java:1172) | |
| at org.apache.cassandra.cql3.statements.SelectStatement.execute(SelectStatement.java:132) | |
| at org.apache.cassandra.cql3.statements.SelectStatement.execute(SelectStatement.java:62) | |
| at org.apache.cassandra.cql3.QueryProcessor.processStatement(QueryProcessor.java:132) | |
| at org.apache.cassandra.cql3.QueryProcessor.process(QueryProcessor.java:143) |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| CREATE TABLE http_by_source ( | |
| source text, | |
| date timestamp, | |
| column2 text, | |
| column3 text, | |
| column4 text, | |
| value text, | |
| PRIMARY KEY (source, date, column2, column3, column4) | |
| ) WITH COMPACT STORAGE AND | |
| bloom_filter_fp_chance=0.010000 AND |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| def py_insert(cf, listOfRecordsAsDict): | |
| if cf not in columnfamilies: | |
| columnfamilies[cf] = ColumnFamily(py_pool, cf) | |
| try: | |
| columnfamilies[cf].batch_insert(listOfRecordsAsDict) | |
| except Exception, e: | |
| logger.warning('Write failure. Waiting 1 second and trying again'); | |
| time.wait(1) | |
| try: |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| from pycassa.pool import ConnectionPool | |
| from pycassa.columnfamily import ColumnFamily | |
| from pycassa.index import * | |
| from pycassa.types import * | |
| pool = ConnectionPool('keyspace',['localhost:9160'] | |
| my_cf = ColumnFamily(pool,'my_cf') | |
| def getRecords(colVal): | |
| col_expr = create_index_expression('colName', colVal, EQ) |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| import me.mcnelis.rudder.data.Feature; | |
| import me.mcnelis.rudder.data.Label; | |
| import me.mcnelis.rudder.data.Record; | |
| public class Flower extends Record { | |
| @Label | |
| protected String species; | |
| @Feature |
NewerOlder