Thrift.Transport.ttransportException: Não é possível gravar no NULL OutputStream
Pergunta
Estou trabalhando com Cassandra e as bibliotecas de economia. Sei que essas são bibliotecas muito precoces e (sem dúvida) mudam em algum momento.
Eu tenho usado o seguinte link Para obter ajuda na configuração do meu código C# para gravar e ler de e para o meu servidor Cassandra (que tenho executando uma instância do servidor Ubuntu no meu VirtualBox local). Eu confirmei que a funcionalidade trivial de leitura / gravação funciona.
Onde estou tendo um problema, é executar o seguinte método (que foi gerado para mim usando o arquivo Thrift.Definition que veio com Cassandra):
public void send_get_count(string keyspace, string key, ColumnParent column_parent, ConsistencyLevel consistency_level)
Aqui está o meu código de configuração:
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);
}
Meu código de chamada parece assim:
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));
}
}
}
A primeira linha desse método é onde estou recebendo minha exceção:
oprot_.WriteMessageBegin(new TMessage("get_count", TMessageType.Call, seqid_));
E aqui está a exceção:
Thrift.Transport.TTransportException: Cannot write to null outputstream at Thrift.Transport.TStreamTransport.Write(Byte[] buf, Int32 off, Int32 len) at Thrift.Protocol.TBinaryProtocol.WriteI32(Int32 i32) at Thrift.Protocol.TBinaryProtocol. WriteMessageBegin (mensagem tMessage) em apache.casandra.cassandra.client.send_get_range_slice (string keyspace, columnparent column_parent, slicePredicate predefate, string start_key, string finalize_key, lhends row_count, constituição de consistência_level_level) em strings, string_key, rate_count, constitui -sen1. .Client.get_range_slice (string de chaves, columnparent column_parent, slicepredicate Predicate, string start_key, string finalize_key, int32 row_count, consistência consistência_level) em Cassandra.cs: linha 335 at Cassandrademo.models.tentreieslblobsBloslBlates: em Cassandrademo.tests.models.testtest.test_getallblogentries_success () em testtest.cs: linha 42
Alguma ideia?
Solução
Você precisa ligar para o Open () no transporte.