Thrift.Transport.TTransportException：无法写入空输出流

我正在与Cassandra和Thrift库一起工作。我意识到这些都是非常早期的图书馆，并且会在某些时候（无疑）发生变化。Thrift.Transport.TTransportException：无法写入空输出流

我一直在使用以下link来设置我的C＃代码，以便从我的Cassandra服务器（我在本地VirtualBox的Ubuntu服务器实例中运行）进行读写操作。我已经确认了这些微不足道的读/写功能。

当我在被执行下面的方法（这是使用与卡桑德拉附带的thrift.definition文件对我产生的）一个问题：

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

，这里是例外：

Thrift.Transport.TTransportException：不能写在Thrift.Transport.TStreamTransport.Write为空的OutputStream （字节[] buf中，的Int32断，的Int32 LEN）在Thrift.Protocol.TBinaryProtocol.WriteI32（的Int32 I32）在Thrift.Protocol.TBinaryProtocol.WriteMessageBegin（TMessage消息）在Apache.Cassandra.Cassandra.Client.send_get_range_slice（字符串密钥空间，ColumnParent column_parent，SlicePredicate谓词，字符串start_key，字符串finish_key，Int32 row_count，ConsistencyLevel consis tency_level）在Cassandra.cs中：行341 位于Cassandra.cs中的Apache.Cassandra.Cassandra.Client.get_range_slice（String keyspace，ColumnParent column_parent，SlicePredicate predicate，String start_key，String finish_key，Int32 row_count，ConsistencyLevel consistency_level）：line 335 在CassandraDemo.Models.Test.GetAllBlogEntries（）在test.cs中：行TestTest.cs 212 在CassandraDemo.Tests.Models.TestTest.Test_GetAllBlogEntries_Success（）：线42

任何想法？

来源

2010-03-09 karlgrz

声音就像输出流为空。你如何初始化_client？ – Schildmeijer 2010-03-09 17:42:10

@Schildmeijer我会更新我的设置代码。该对象是绝对创建的，因为我可以在调用此代码之前进行读写。 – karlgrz 2010-03-09 18:48:34

我不认为实际上在C＃中使用Cassandra的人实际上是在SO上，所以如果你不能在这里弄清楚它，请尝试询问cassandra用户邮件列表。 – jbellis 2010-03-10 15:06:13

您需要在传输上调用Open（）。

来源

2010-03-10 06:58:11 Schildmeijer

就是这样！我昨天晚上在火车回家的路上想到了这一点，但刚回到工作检查SO。谢谢你的帮助！ – karlgrz 2010-03-10 16:42:12

Thrift.Transport.TTransportException：无法写入空输出流

回答

相关问题