Return-Path: Delivered-To: apmail-cassandra-user-archive@www.apache.org Received: (qmail 35710 invoked from network); 14 Oct 2010 23:33:02 -0000 Received: from unknown (HELO mail.apache.org) (140.211.11.3) by 140.211.11.9 with SMTP; 14 Oct 2010 23:33:02 -0000 Received: (qmail 19900 invoked by uid 500); 14 Oct 2010 23:33:00 -0000 Delivered-To: apmail-cassandra-user-archive@cassandra.apache.org Received: (qmail 19878 invoked by uid 500); 14 Oct 2010 23:33:00 -0000 Mailing-List: contact user-help@cassandra.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@cassandra.apache.org Delivered-To: mailing list user@cassandra.apache.org Received: (qmail 19870 invoked by uid 99); 14 Oct 2010 23:33:00 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 14 Oct 2010 23:33:00 +0000 X-ASF-Spam-Status: No, hits=2.9 required=10.0 tests=HTML_MESSAGE,RCVD_IN_DNSWL_NONE,SPF_NEUTRAL X-Spam-Check-By: apache.org Received-SPF: neutral (nike.apache.org: local policy) Received: from [209.85.216.179] (HELO mail-qy0-f179.google.com) (209.85.216.179) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 14 Oct 2010 23:32:53 +0000 Received: by qyk36 with SMTP id 36so203447qyk.10 for ; Thu, 14 Oct 2010 16:32:32 -0700 (PDT) MIME-Version: 1.0 Received: by 10.224.45.16 with SMTP id c16mr8202913qaf.310.1287099151533; Thu, 14 Oct 2010 16:32:31 -0700 (PDT) Received: by 10.229.24.5 with HTTP; Thu, 14 Oct 2010 16:32:31 -0700 (PDT) Date: Thu, 14 Oct 2010 17:32:31 -0600 Message-ID: Subject: Cassandra/Pelops error processing get_slice From: Frank LoVecchio To: user@cassandra.apache.org Content-Type: multipart/alternative; boundary=00c09f972144b7c79f04929c1f51 X-Virus-Checked: Checked by ClamAV on apache.org --00c09f972144b7c79f04929c1f51 Content-Type: text/plain; charset=ISO-8859-1 10:10:21,787 ERROR ~ Error getting Sensor org.apache.thrift.TApplicationException: Internal error processing get_slice at org.apache.thrift.TApplicationException.read( TApplicationException.java:108) at org.apache.cassandra.thrift.Cassandra$Client.recv_get_slice( Cassandra.java:544) at org.apache.cassandra.thrift.Cassandra$Client.get_slice(Cassandra.java:524 ) at org.scale7.cassandra.pelops.Selector$6.execute(Selector.java:538) at org.scale7.cassandra.pelops.Selector$6.execute(Selector.java:535) at org.scale7.cassandra.pelops.Operand.tryOperation(Operand.java:45) at org.scale7.cassandra.pelops.Selector.getSuperColumnsFromRow( Selector.java:545) at org.scale7.cassandra.pelops.Selector.getSuperColumnsFromRow( Selector.java:522) Not sure if this is a pelops thing or thrift. I spun up a new cluster of 3 nodes a couple of nights ago with the nightly build 0.7 beta 2's. When I include all 3 nodes in the Pelops Pool, and run this: List cols = selector.getSuperColumnsFromRow( getColFamilyName(), key, Selector.newColumnsPredicateAll(true, 1000), ConsistencyLevel.ONE); I get the error above. When I create a new Pool with only 1 node, I get different data back then if I create a new Pool with another single node, but I don't get the error. Why is this happening? Here is my cassandra.yaml file, which I haven't modified on the fly: # Configuration wiki: http://wiki.apache.org/cassandra/StorageConfiguration authority: org.apache.cassandra.auth.AllowAllAuthority authenticator: org.apache.cassandra.auth.AllowAllAuthenticator auto_bootstrap: true binary_memtable_throughput_in_mb: 256 cluster_name: DevCluster column_index_size_in_kb: 64 commitlog_directory: /cassandra/commitlog saved_caches_directory: /cassandra/saved_caches commitlog_rotation_threshold_in_mb: 128 commitlog_sync: periodic commitlog_sync_period_in_ms: 10000 concurrent_reads: 8 concurrent_writes: 50 data_file_directories: - /cassandra/data disk_access_mode: auto endpoint_snitch: org.apache.cassandra.locator.SimpleSnitch dynamic_snitch: true hinted_handoff_enabled: true in_memory_compaction_limit_in_mb: 256 keyspaces: - name: Keyspace replica_placement_strategy: org.apache.cassandra.locator.SimpleStrategy replication_factor: 3 column_families: - name: Sensor column_type: Super compare_with: TimeUUIDType gc_grace_seconds: 864000 keys_cached: 200000.0 preload_row_cache: false read_repair_chance: 1.0 rows_cached: 0.0 listen_address: ec2-internal-ip1 memtable_flush_after_mins: 60 memtable_operations_in_millions: 0.3 memtable_throughput_in_mb: 64 partitioner: org.apache.cassandra.dht.RandomPartitioner phi_convict_threshold: 8 rpc_port: 9160 rpc_timeout_in_ms: 10000 seeds: - ec2-internal-ip1 - ec2-internal-ip2 - ec2-internal-ip3 sliced_buffer_size_in_kb: 64 snapshot_before_compaction: false storage_port: 7000 thrift_framed_transport_size_in_mb: 15 thrift_max_message_length_in_mb: 16 initial_token: Frank LoVecchio Software Engineer Isidorey LLC franklovecchio.com rodsandricers.com --00c09f972144b7c79f04929c1f51 Content-Type: text/html; charset=ISO-8859-1 Content-Transfer-Encoding: quoted-printable

10:10:21,787 ERROR ~ Error getting Sensor=A0

org.apache.thrift.TA= pplicationException: Internal = error processing get_slice

at org.apache.= thrift.TApplicationException.read(TApplicationException.java:108)

at org.apache.= cassandra.thrift.Cassandra$Client.recv_get_slice(Cassandra.java:544)

at org.apache.= cassandra.thrift.Cassandra$Client.get_slice(Cassandra.java:524)

at org.scale7.= cassandra.pelops.Selector$6.execute(Selector.java:538)

at org.scale7.= cassandra.pelops.Selector$6.execute(Selector.java:535)

at org.scale7.= cassandra.pelops.Operand.tryOperation(Operand.java:45)

at org.scale7.= cassandra.pelops.Selector.getSuperColumnsFromRow(Selector.java:545)

at org.scale7.= cassandra.pelops.Selector.getSuperColumnsFromRow(Selector.java:522)


Not sure if this is a pelops thing or thr= ift.


I spun up a new cluster of 3 nodes=A0a couple of nights= ago=A0with the nightly build 0.7 beta 2's. =A0When I include all 3 nod= es in the Pelops Pool, and run this:

List<SuperColumn> cols =3D selector.= getSuperColumnsFromRow(
=A0=A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 getColFamily= Name(), key,
=A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0= =A0Selector.newColumnsPredicateAll(true, 1000),
=A0 =A0 =A0 =A0 =A0 =A0= =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0ConsistencyLevel.ONE);
=

=A0I get the error above= . =A0When I create a new Pool with only 1 node, I get different data back t= hen if I create a new Pool with another single node, but I don't get th= e error. =A0Why is this happening? =A0Here is my cassandra.yaml file, which= I haven't modified on the fly:

authority: org.apache.cassandra.auth.AllowAllAuthority
authe= nticator: org.apache.cassandra.auth.AllowAllAuthenticator
auto_bo= otstrap: true
binary_memtable_throughput_in_mb: 256
cluster_name: DevCluster
column_index_size_in_kb: 64
co= mmitlog_directory: /cassandra/commitlog
saved_caches_directory: /= cassandra/saved_caches
commitlog_rotation_threshold_in_mb: 128
commitlog_sync: periodic
commitlog_sync_period_in_ms: 10000<= /div>
concurrent_reads: 8
concurrent_writes: 50
dat= a_file_directories:
- /cassandra/data
disk_access_mode:= auto
endpoint_snitch: org.apache.cassandra.locator.SimpleSnitch
d= ynamic_snitch: true
hinted_handoff_enabled: true
in_mem= ory_compaction_limit_in_mb: 256
keyspaces:
=A0=A0 =A0- = name: Keyspace
=A0=A0 =A0 =A0replica_placement_strategy: org.apache.cassandra.locator= .SimpleStrategy
=A0=A0 =A0 =A0replication_factor: 3
=A0= =A0 =A0 =A0column_families:
=A0=A0 =A0=A0
=A0=A0 =A0 = =A0 =A0- name: Sensor
=A0=A0 =A0 =A0 =A0 =A0column_type: Super
=A0=A0 =A0 =A0 =A0 =A0compare_with: TimeUUIDType
=A0=A0 =A0 = =A0 =A0 =A0gc_grace_seconds: 864000
=A0=A0 =A0 =A0 =A0 =A0keys_ca= ched: 200000.0
=A0=A0 =A0 =A0 =A0 =A0preload_row_cache: false
=A0=A0 =A0 =A0 =A0 =A0read_repair_chance: 1.0
=A0=A0 =A0 =A0 =A0 =A0rows_cached: 0.0
=A0
listen_= address: ec2-internal-ip1
memtable_flush_after_mins: 60
memtable_operations_in_millions: 0.3
memtable_throughput_in_mb: = 64
partitioner: org.apache.cassandra.dht.RandomPartitioner
phi_convi= ct_threshold: 8
rpc_port: 9160
rpc_timeout_in_ms: 10000=
seeds:
- ec2-internal-ip1
-=A0ec2-internal-i= p2
-=A0ec2-internal-ip3
sliced_buffer_size_in_kb: 64
= snapshot_before_compaction: false
storage_port: 7000
th= rift_framed_transport_size_in_mb: 15
thrift_max_message_length_in= _mb: 16
initial_token:

Frank LoVecchio
Software Engineer
Isidorey LLC

--00c09f972144b7c79f04929c1f51--