Вставка в Cassandra через thrift-client не работает после удаления строки через cassandra-cli

Я написал простой тест, чтобы проверить мое собственное понимание экономичного интерфейса для Cassandra. Он просто вставляет строку в базу данных (используя пространство ключей и семейство столбцов, которые предварительно настроены при установке cassandra), затем считывает ее из базы данных и сравнивает результаты.

public class CassandraAPITest {
    @Test
    public void testCassandraAPI() throws Exception {
        TTransport tr = new TSocket("localhost", 9160);
        tr.open();
        Client client = new Cassandra.Client(new TBinaryProtocol(tr));
        String key = "123";
        byte[] value = { 52, 53, 54 };
        ColumnPath columnPath = new ColumnPath("Standard1");
        columnPath.setColumn("abc".getBytes("UTF8"));
        long timestamp = System.currentTimeMillis();

       client.insert("Keyspace1", key, columnPath, value, timestamp, ConsistencyLevel.ONE);

        SlicePredicate predicate = new SlicePredicate();
        SliceRange sliceRange = new SliceRange();
        sliceRange.setStart(new byte[0]);
        sliceRange.setFinish(new byte[0]);
        predicate.setSlice_range(sliceRange);

        List<ColumnOrSuperColumn> result = client.get_slice("Keyspace1", key, new ColumnParent("Standard1"), predicate, ConsistencyLevel.ONE);

        assertEquals(1, result.size());
        byte[] actual = result.get(0).column.value;
        assertArrayEquals(value, actual);

        // client.remove("Keyspace1", key, columnPath, System.currentTimeMillis(), ConsistencyLevel.ONE);

        tr.close();
    }
}

Этот тест проходит нормально. Конечно, в базе данных остается строка. Я мог бы удалить строку в конце теста, раскомментировав оператор client.remove выше (это тоже отлично работает). Но вместо этого я попытался удалить строку через интерфейс командной строки:

cassandra> connect localhost/9160                   
Connected to: "Test Cluster" on localhost/9160
cassandra> get Keyspace1.Standard1['123']
=> (column=616263, value=456, timestamp=1287909211506)
Returned 1 results.
cassandra> del Keyspace1.Standard1['123']   
row removed.
cassandra> get Keyspace1.Standard1['123']
Returned 0 results.

После этого тест не прошел. Кажется, что вставка строки в базу данных больше не действует, поэтому строка assertEquals (1, result.size ()) не работает:

java.lang.AssertionError: expected:<1> but was:<0>
    at org.junit.Assert.fail(Assert.java:91)
    at org.junit.Assert.failNotEquals(Assert.java:618)
    at org.junit.Assert.assertEquals(Assert.java:126)
    at org.junit.Assert.assertEquals(Assert.java:443)
    at org.junit.Assert.assertEquals(Assert.java:427)
    at test.package.CassandraAPITest.testCassandraAPI(CassandraAPITest.java:48)

Я не получаю сообщений об ошибках (ни на клиенте, ни на сервере) и Понятия не имею, в чем может быть причина проблемы.

1
задан sme 24 October 2010 в 09:04
поделиться