SSTableWriter error: incorrect row data size

[Eiti Kimura <ei...@movile.com>]

Hello Guys,

Have a cluster with 6 nodes using Cassandra 1.2.
I have my Keyspace and tables created using thrift cassandra-cli.

Now I just created a new table using cqlsh as follows:

CREATE TABLE idx_conf (
  conf_id int,
  ref_id text,
  subs_key text,
  data text,
  enabled boolean,
  expiration timestamp,
  last_charge timestamp,
  last_charge_att timestamp,
  last_queued timestamp,
  master boolean,
  msg_balance int,
  origin_id int,
  seq_index int,
  status_id int,
  PRIMARY KEY (conf_id, subs_key)
) WITH
  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'};

And I wrote a program to add data to this table using Datastax java-driver
version 2.1.5.

So I created my cluster with right protocol version for Cassandra 1.2
version:
 cluster = Cluster.builder()
                         .addContactPoints(addresses)
                         .withProtocolVersion(ProtocolVersion.V1)

 .withRetryPolicy(DowngradingConsistencyRetryPolicy.INSTANCE)
                         .withReconnectionPolicy(new
ExponentialReconnectionPolicy(1000L, 30000L))
                         .withLoadBalancingPolicy(new
DCAwareRoundRobinPolicy())
                         .build();

The inserts, updates and queries are working fine, but I saw some weird
exceptions in Cassandra server's log (system.log):

ERROR [CompactionExecutor:6523] 2015-10-09 12:33:23,551
CassandraDaemon.java (line 191) Exception in thread
Thread[CompactionExecutor:6523,1,main]
java.lang.AssertionError: incorrect row data size 568009715 written to
/movile/cassandra-data/SBSPlatform/idx_config/SBSPlatform-idx_config-tmp-ic-715-Data.db;
correct is 568010203
at
org.apache.cassandra.io.sstable.SSTableWriter.append(SSTableWriter.java:162)
at
org.apache.cassandra.db.compaction.CompactionTask.runWith(CompactionTask.java:162)
at
org.apache.cassandra.io.util.DiskAwareRunnable.runMayThrow(DiskAwareRunnable.java:48)
at org.apache.cassandra.utils.WrappedRunnable.run(WrappedRunnable.java:28)
at
org.apache.cassandra.db.compaction.CompactionTask.executeInternal(CompactionTask.java:58)
at
org.apache.cassandra.db.compaction.AbstractCompactionTask.execute(AbstractCompactionTask.java:60)
at
org.apache.cassandra.db.compaction.CompactionManager$BackgroundCompactionTask.run(CompactionManager.java:208)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:744)

Looks like that SSTableWriter was not able to flush data to disk when
writing the new table: SBSPlatform-idx_config-tmp-ic-715-Data.db

Can you help me with that?
What are the consequences of this errors?
Thanks

J.P. Eiti Kimura
Plataformas

+55 19 3518  <https://www.movile.com/assinaturaemail/#>5500
+ <https://www.movile.com/assinaturaemail/#>55 19 98232 2792
skype: eitikimura
<https://www.linkedin.com/company/movile>
<https://pt.pinterest.com/Movile/>  <https://twitter.com/movile_LATAM>
<https://www.facebook.com/Movile>