Hi,
The exception occurs on the clients. The server is fine. FYI, I dont do any
reads, only writes to cassandra. I re-run the experiment everytime after
dropping all the created columnfamilies and key spaces.
Thanks...
On Sun, Dec 1, 2013 at 4:57 AM, Krishna Chaitanya <bnsk1990r...@gmail.com>wrote:
> Hi,
> Thanks for the reply Aaron... There is no error stack! Just a
> single exception which says, "terminate called after
> IllegalRequestException what(): Default TException. When I try to send the
> same amount of data from a single node to a single cassandra node, it works
> fine. But, when I split this data and send from multiple nodes to a single
> node, it results in this exception. I'm trying to run the same
> program(stores data) from multiple nodes to write to a single cassandra
> node. What all are the possible reasons for this exception? I don't think
> its the load, since if I send the same amount of data from a single node,
> it works fine. Is this correct?
> I am giving below the cassandra related code of my program. This same
> program should run on multiple nodes, but its not. I'm feeling I'm doing
> something fundamentally wrong since I'm aware that it's possible to store
> to a single cassandra node from multiple sources without using any
> locks(Locking isn't required right?). Here is the cassandra related code...
>
> char mycassa_host[20];
> int mycassa_port(9160);
> const char *password("");
> const char *table_name("ovs_netflow_table");
> const char *context("ntopng_data");
> QtCassandra::QCassandra mycassa;
> int j;
> char str[1500];
>
>
> //prompt user to enter the ip of the cassandra node...
> qDebug()<< "Please enter the ip of the cassandra host: \n" ;
> fscanf(stdin,"%s", mycassa_host);
> qDebug() << "using host:port:: "<<mycassa_host << "and
> port:9160\n" ;
>
> if(!mycassa.connect(mycassa_host,mycassa_port,password)) //connecting
> to the cassandra cluster...
> {
> qDebug()<<"\nSorry couldnt connect to the db\n";
> exit(1);
> }
>
> qDebug() << "Working on Cassandra Cluster Named" <<
> mycassa.clusterName();
> qDebug() << "Working on Cassandra Protocol Version" <<
> mycassa.protocolVersion();
>
> QSharedPointer<QtCassandra::QCassandraContext>
> thiscontext(mycassa.context(context));
>
> try{
> thiscontext->drop();
> mycassa.synchronizeSchemaVersions();
>
> }
> catch(...){
> //ignore errors...this happens if the context doesn't exist yet...
> }
>
> thiscontext->setStrategyClass("SimpleStrategy");
> thiscontext->setReplicationFactor(1);
>
> QSharedPointer<QtCassandra::QCassandraTable>
> tableptr(thiscontext->table(table_name));
>
> tableptr->setColumnType("Standard");
> tableptr->setComment("This is a store for netflows sent by OVS");
> tableptr->setKeyValidationClass("BytesType");
> tableptr->setDefaultValidationClass("BytesType");
> tableptr->setComparatorType("BytesType");
> tableptr->setKeyCacheSavePeriodInSeconds(14400);
> tableptr->setMemtableFlushAfterMins(60);
> tableptr->setGcGraceSeconds(3600); // 1h.
> tableptr->setMinCompactionThreshold(4);
> tableptr->setMaxCompactionThreshold(22);
> tableptr->setReplicateOnWrite(1);
>
> thiscontext->create();
> mycassa.synchronizeSchemaVersions();
>
> while(1)
> {
> //code for reading and storing a netflow packet from memory to a
> QByteArray bin;
>
> QtCassandra::QCassandraValue value(bin);
> QByteArray rowkey;
> rowkey.append((char)(i));
> mycassa["ntopng_data"]["ovs_netflow_table"][rowkey]["col"]= value;
>
> }
>
>
> Note that this same code runs in multiple systems. Could this be a
> problem?
>
>
> Thanks...
>
>
>
>
>
>
>
>
>
>
>
>
>
> On Thu, Nov 28, 2013 at 4:25 PM, Aaron Morton <aa...@thelastpickle.com>wrote:
>
>> I am a newbie to the Cassandra world. I would like to know if its
>> possible for two different nodes to write to a single Cassandra node
>>
>> Yes.
>>
>> Currently, I am getting a IllegalRequestException, what (): Default
>> TException on the first system,
>>
>> What is the full error stack ?
>>
>>
>> Occasionally, also hitting "frame size has negative value" thrift
>> exception when the traffic is high and packets are getting stored very fast.
>>
>> On the client or the server ? Can you post the full error stack ?
>>
>> Currently using Cassandra 2.0.0 with libQtCassandra library.
>>
>> Please upgrade to 2.0.3.
>>
>> Cheers
>>
>> -----------------
>> Aaron Morton
>> New Zealand
>> @aaronmorton
>>
>> Co-Founder & Principal Consultant
>> Apache Cassandra Consulting
>> http://www.thelastpickle.com
>>
>> On 26/11/2013, at 4:42 am, Krishna Chaitanya <bnsk1990r...@gmail.com>
>> wrote:
>>
>> Hello,
>> I am a newbie to the Cassandra world. I would like to know if its
>> possible for two different nodes to write to a single Cassandra node. I
>> have a packet collector software which runs in two different systems. I
>> would like both of them to write the packets to a single node(same keyspace
>> and columnfamily). Currently using Cassandra 2.0.0 with libQtCassandra
>> library.
>> Currently, I am getting a
>> IllegalRequestException, what (): Default TException on the first system,
>> the moment I try to store from the second system, but the second system
>> works fine. When I restart the program on the first system, the second
>> system gets the exception and the first one works fine. Occasionally, also
>> hitting "frame size has negative value" thrift exception when the traffic
>> is high and packets are getting stored very fast.
>> Can someone please point out what I am doing wrong? Thanks in advance..
>>
>>
>>
>
>
> --
> Regards,
> BNSK
> *. *
>
--
Regards,
BNSK
*. *
