Thrift.Transport.TTransportException:OutputStreamをnullに書き込めません
質問
私はカサンドラとスリフトライブラリといくつかの仕事をやっています。私は、これらが非常に早いのライブラリであり、いくつかの点であろう(間違い)の変化を実現します。
私は設定のヘルプについては、以下のリンクを使用してきました書き込みとすると(私は私の地元のVirtualBoxでUbuntuのサーバインスタンスで実行している)私のカサンドラサーバーから読み込むための私のC#のコードアップ。私は些細な読み取り/書き込み機能が動作することを確認しました。
私は(カサンドラに付属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:ヌルOutputStreamに書き込むことができません Thrift.Transport.TStreamTransport.Write(バイト[] BUF、のInt32オフ、のInt32 LEN)で Thrift.Protocol.TBinaryProtocol.WriteI32(のInt32 I32)で Thrift.Protocol.TBinaryProtocol.WriteMessageBegin(TMessageメッセージ)で Apache.Cassandra.Cassandra.Client.send_get_range_slice Cassandra.csに(文字列鍵空間、ColumnParentのcolumn_parent、SlicePredicate述語、文字列start_key、文字列finish_key、のInt32 ROW_COUNT、ConsistencyLevelのconsistency_level)において:ライン341 Apache.Cassandra.Cassandra.Client.get_range_slice Cassandra.csに(文字列鍵空間、ColumnParentのcolumn_parent、SlicePredicate述語、文字列start_key、文字列finish_key、のInt32 ROW_COUNT、ConsistencyLevelのconsistency_level)において:ライン335 ライン212:Test.csでCassandraDemo.Models.Test.GetAllBlogEntries()で CassandraDemo.Tests.Models.TestTest.Test_GetAllBlogEntries_Success()TestTest.cs中で:ライン42
任意のアイデア?
解決
あなたは輸送上のオープンを()を呼び出す必要があります。