Thrift.Transport.TTransportException: Null çıkışa yazamıyor

Question

Cassandra ve Thrift kitaplıklarıyla çalışıyorum. Bunların çok erken kütüphaneler olduğunu ve bir noktada (şüphesiz) değişeceğini fark ettim.

C# kodumu yazıp, benim Cassandra sunucumdan (yerel VirtualBox'umda bir Ubuntu Sunucusu örneğinde çalıştığım) okuma ve yazma konusunda yardım için aşağıdaki link'u kullanıyorum. Önemsiz okuma/yazma işlevinin çalıştığını onaylamıştım.

I (Cassandra birlikte gelen thrift.definition dosyasını kullanarak benim için oluşturulan) aşağıdaki yöntemi yürütürken bir sorun yaşıyorum Nerede:

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 send_get_count(string keyspace, string key, ColumnParent column_parent, ConsistencyLevel consistency_level) 

İşte benim Kurulum kodu var

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

Bu yöntemin ilk satırı nerede: şöyle

My çağıran kod görünüyor istisna burada

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

Ve edilir:

Thrift.Transport.TTransportException: Ben özel durum alıyorum Thrift.Transport.TStreamTransport.Write de OutputStream null yazılamıyor (Byte [] tampon, Int32 kapalı, Apache.Cassandra.Cassandra.Client.send_get_range_slice (string keyspace, ColumnParent column_parent, SlicePredicate de Thrift.Protocol.TBinaryProtocol.WriteMessageBegin (Tmessage mesajı) de Thrift.Protocol.TBinaryProtocol.WriteI32 (Int32 i32) de ınt32 len) yüklem, Dize start_key, Dize finish_key, Int32 row_count, ConsistencyLevel consis Cassandra.cs: satır 341 Apache.Cassandra.Cassandra.Client.get_range_slice (String keyspace, ColumnParent column_parent, SlicePredicate yüklemi, String başlangıç_anahtarı, String finish_key, Int32 row_count, ConsistencyLevel Tutarlılık_level), Cassandra.cs: satır 335 hat TestTest.cs içinde CassandraDemo.Tests.Models.TestTest.Test_GetAllBlogEntries_Success() at 212 : satır 42

Herhangi bir fikir Test.cs içinde CassandraDemo.Models.Test.GetAllBlogEntries() at?

Answer 1

Taşımada Open() öğesini çağırmanız gerekir.