Astyanax: prosty zapis rzucający ten wyjątek: za mało bajtów, aby odczytać wartość komponentu

Question

Jestem nowicjuszem astyanax i wypróbowuję niektóre przykładowe programy i otrzymuję ten błąd. To jest prosty zapis i wygląda na to, że robię coś podstawowego. Nie używa się kluczy złożonych.

Caused by: InvalidRequestException(why:Not enough bytes to read value of component 0) 
    at org.apache.cassandra.thrift.Cassandra$batch_mutate_result.read(Cassandra.java:20833) 
    at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:78) 
    at org.apache.cassandra.thrift.Cassandra$Client.recv_batch_mutate(Cassandra.java:964) 
    at org.apache.cassandra.thrift.Cassandra$Client.batch_mutate(Cassandra.java:950) 
    at com.netflix.astyanax.thrift.ThriftKeyspaceImpl$1$1.internalExecute(ThriftKeyspaceImpl.java:120) 
    at com.netflix.astyanax.thrift.ThriftKeyspaceImpl$1$1.internalExecute(ThriftKeyspaceImpl.java:117) 
    at com.netflix.astyanax.thrift.AbstractOperationImpl.execute(AbstractOperationImpl.java:56) 

Oto kod:

AstyanaxContext<Keyspace> context = new AstyanaxContext.Builder() 
     .forCluster(CLUSTER_NAME) 
     .forKeyspace(keySpaceName) 
     .withAstyanaxConfiguration(new AstyanaxConfigurationImpl()  
      .setDiscoveryType(NodeDiscoveryType.RING_DESCRIBE) 
      .setCqlVersion("3.0.0") 
      .setTargetCassandraVersion("1.2") 
     ) 
     .withConnectionPoolConfiguration(new ConnectionPoolConfigurationImpl("MyConnectionPool") 
      .setPort(50825) 
      .setMaxConnsPerHost(10) 
      .setSeeds("nodename:50825") 
      .setConnectTimeout(20000) 
     ) 
     .withConnectionPoolMonitor(new CountingConnectionPoolMonitor()) 
     .buildKeyspace(ThriftFamilyFactory.getInstance()); 

    context.start(); 
    System.out.println("getting context.. done "); 
    Keyspace keyspace = context.getEntity(); 
    MutationBatch m = keyspace.prepareMutationBatch(); 

    ColumnFamily<String, String> colFam = new ColumnFamily<String, String>("test", 
      StringSerializer.get(), StringSerializer.get()); 

    m.withRow(colFam, "abc") 
     .putColumn("col2", "test1", null); 
    m.execute(); 

Oto tabela opisują:

CREATE TABLE test (
col1 text PRIMARY KEY, 
col2 text, 
col3 text 
) 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'}; 

Answer 1

Jestem również nowy w Astyanax i zbliżą się do tych samych wyjątków. Wyjątek wynika z niedopasowania między tym, co Astyanax - obiekty oparte na Thrift uważają, że definicja kolumny powinna wyglądać i jak to jest przechowywać w wersji 1.2+ przy użyciu CQL 3. Nauczyłem się określając COMPACT STORAGE, aby tabela została utworzona w formacie pre 1.2 pozwól mi współdziałać z nim za pośrednictwem obiektów opartych na oszczędzaniu. FWIW: Buduję Astyanax ze źródła, ale widziałem 1.56.34 w centrum maven; Chciałbym również zaktualizować to.

CREATE TABLE test (
col1 text PRIMARY KEY, 
col2 text, 
col3 text 
) WITH COMPACT STORAGE AND 
... 

Zobacz Working with pre-CQL 3 applications

Answer 2

I Rozwiązanie dostarczone przez user2251060 spełnia swoje zadanie. Ponadto Netflix pracuje nad nową wersją Astyanax, która zależy od sterownika Jastrzębie Datastax, aby konwertować oszczędzane obiekty na bazujące na bazach CQL. Możesz znaleźć więcej informacji na https://github.com/Netflix/astyanax/wiki/Astyanax-over-Java-Driver