Thrift.Transport.TTransportException: Impossibile scrivere a null OutputStream

Question

che sto facendo un po 'di lavoro con Cassandra e le librerie di risparmio. Mi rendo conto che questi sono molto precoci librerie e volontà (senza dubbio) il cambiamento ad un certo punto.

Ho usato le seguenti link aiuto per l'impostazione il mio codice C # per scrivere e leggere da e verso il mio server Cassandra (che ho in esecuzione in un'istanza di Ubuntu Server nella mia VirtualBox locale). Ho confermato che la funzionalità di lettura / scrittura banale funziona.

Dove sto avendo un problema sta eseguendo il seguente metodo (che è stato generato per me utilizzando il file thrift.definition fornito con Cassandra):

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

Ecco il mio codice di installazione:

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);
}

Il mio codice chiamante appare in questo modo:

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));                        
            }
        }
    } 

La prima linea di questo metodo è dove sto ottenendo la mia eccezione:

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

E qui è l'eccezione:

Thrift.Transport.TTransportException: Impossibile scrivere a null OutputStream a Thrift.Transport.TStreamTransport.Write (Byte [] buf, Int32 off, Int32 len) a Thrift.Protocol.TBinaryProtocol.WriteI32 (Int32 i32) a Thrift.Protocol.TBinaryProtocol.WriteMessageBegin (messaggio TMessage) a Apache.Cassandra.Cassandra.Client.send_get_range_slice (String spazio delle chiavi, ColumnParent column_parent, SlicePredicate predicato, String start_key, String finish_key, Int32 row_count, ConsistencyLevel consistency_level) in Cassandra.cs: linea 341 a Apache.Cassandra.Cassandra.Client.get_range_slice (String spazio delle chiavi, ColumnParent column_parent, SlicePredicate predicato, String start_key, String finish_key, Int32 row_count, ConsistencyLevel consistency_level) in Cassandra.cs: linea 335 a CassandraDemo.Models.Test.GetAllBlogEntries () in Test.cs: la linea 212 a CassandraDemo.Tests.Models.TestTest.Test_GetAllBlogEntries_Success () in TestTest.cs: linea 42

Tutte le idee?

Answer 1

È necessario chiamare Open () sul trasporto.