Экономия. Транспорт. TTransportException: не Может записать в пустой указатель outputstream

Я делаю некоторую работу с Cassandra и библиотеками Thrift. Я понимаю, что они - очень ранние библиотеки и (несомненно) изменятся в какой-то момент.

Я использовал следующую ссылку для справки с устанавливанием моего кодекса C#, чтобы записать и читать в и с моего сервера Cassandra (который у меня есть выполнение в экземпляре Сервера Ubuntu в моем локальном VirtualBox). Я подтвердил, что тривиальное чтение / пишет работы функциональности.

То, где у меня есть проблема, выполняет следующий метод (который был сгенерирован для меня использующий thrift.definition файл, который шел с Cassandra):

public void send_get_count(string keyspace, string key, ColumnParent column_parent, ConsistencyLevel consistency_level)

Вот мой код установки:

TTransport _transport;
TProtocol _protocol;
Cassandra.Client _client;

public Test()
{
    _transport = new TSocket("192.168.56.101", 9160);
    _protocol = new TBinaryProtocol(_transport);
    _client = new Cassandra.Client(_protocol);
}

Мой код вызова похож так:

public void GetAllBlogEntries()
    {
        var timestamp = DateTime.Now.Millisecond;
        var keyspace = "Keyspace1";

        var utf8Encoding = System.Text.Encoding.UTF8;

        var columnParent = new ColumnParent() {Column_family = "BlogEntries"};
        var predicate = new SlicePredicate()
        {
            Slice_range = new SliceRange()
                          {
                              Start = new byte[0],
                              Finish = new byte[0],
                              Count = 10,
                              Reversed = false
                          }
        };

        var results = _client.get_range_slice(keyspace, columnParent, predicate, "", "", 5, ConsistencyLevel.ONE);

        foreach(var slice in results)
        {
            Console.WriteLine("Found Key: {0}", slice.Key);
            foreach(var resultColumn in slice.Columns)
            {
                var column = resultColumn.Column;
                Console.WriteLine("\tName: {0}, value: {1}",
                                  utf8Encoding.GetString(column.Name),
                                  utf8Encoding.GetString(column.Value));                        
            }
        }
    } 

Первая строка этого метода - то, где я получаю свое исключение:

oprot_.WriteMessageBegin(new TMessage("get_count", TMessageType.Call, seqid_));

И вот исключение:

Экономия. Транспорт. TTransportException: не Может записать в пустой указатель outputstream в Thrift. Транспорт. TStreamTransport. Запишите (Байт [] buf, Int32 прочь, Int32 len) в Thrift. Протокол. TBinaryProtocol. WriteI32 (Int32 i32) в Thrift. Протокол. TBinaryProtocol. WriteMessageBegin (сообщение TMessage) в Apache. Cassandra. Cassandra. Клиент send_get_range_slice (Строковое ключевое пространство, ColumnParent column_parent, предикат SlicePredicate, Строка start_key, Строка finish_key, Int32 row_count, ConsistencyLevel consistency_level) в Cassandra.cs: строка 341 в Apache. Cassandra. Cassandra. Клиент get_range_slice (Строковое ключевое пространство, ColumnParent column_parent, предикат SlicePredicate, Строка start_key, Строка finish_key, Int32 row_count, ConsistencyLevel consistency_level) в Cassandra.cs: строка 335 в CassandraDemo. Модели. Тест. GetAllBlogEntries () в Test.cs: строка 212 в CassandraDemo. Тесты. Модели. TestTest. Test_GetAllBlogEntries_Success () в TestTest.cs: строка 42

Какие-либо идеи?

7
задан karlgrz 9 March 2010 в 20:17
поделиться