Hi,
Just found that reducing the batch size below 20 also increases the writing
speed and reduction in memory usage(especially for Python driver).
Kind regards,
Rajesh R
From: Ben Bromhead [b...@instaclustr.com]
Sent: 07 November 2016 05:44
To: user@cassandra.a
Hi Lahiru,
Great! you know what, REDUCTION of BATCH size from 50 to 20 solved my issue.
Thank you very much. Good job man! and Memory issue solved.
Next I will try using Spark to speed it up.
Kind regards,
Rajesh Radhakrishnan
From: Lahiru Gamathige [lah
Hi,
In my case writing is slower using Python driver, using Batch execution and
prepared statements.
I am looking at different ways to speed it up, as I am trying to write 100 *
200 Million records .
Cheers
Rajesh R
From: Vikas Jaiman [er.vikasjai...@gmail.com]
Mon, Nov 7, 2016 at 8:51 AM, Rajesh Radhakrishnan
>
wrote:
Hi
We are trying to inject millions to data into a table by executing Batches of
PreparedStatments.
We found that when we use 'session.execute(batch)', it write more data but very
very slow.
However if we use 'sessio
session = None
del session
cluster = None
del cluster
cassandraCluster = None
del cassandraCluster
gc.collect()
===CODE ==
Kind regards,
Rajesh Radhakrishnan
**
Hi John Z,
Did you tried running with latest Python 2.7.11 or 2.7.12?
Kind regards,
Rajesh Radhakrishnan
From: Ioannis Zafiropoulos [john...@gmail.com]
Sent: 27 October 2016 22:16
To: user@cassandra.apache.org
Subject: cqlsh fails to connect
I upgraded DSE
Hi Vladimir,
Thank you for the response.
Yes I added all the three node IPs while connecting to the cluster via driver.
Its not failed operation. while the script is running and it takes some time to
read millions of data and during this time , I intentionally put one node down
to see how the
Hi,
I have 3 nodes Cassandra cluster.
Cassandra version : dsc-cassandra-2.1.5
Python Cassandra Driver : 2.5.1
Running the nodes in Red Hat virtual machines.
Node ip info:
Node 1: IP_ADDRESS219
Node 2: IP_ADDRESS229
Node 3: IP_ADDRESS230
(IP_ADDRESS219 is masked for this email which represents
assandra/cluster.py", line 3781, in
cassandra.cluster.ResponseFuture.result (cassandra/cluster.c:73073)
cassandra.protocol.ServerError:
======
Kind regards,
Rajesh Radhakrishnan
From: li...@beobal.com [li...@beobal.com] on behalf of Sam Tunnicliffe
[s...@beob
,
Rajesh Radhakrishnan
From: Mehdi Bada [mehdi.b...@dbi-services.com]
Sent: 23 September 2016 08:58
To: user@cassandra.apache.org
Subject: data file directory path customization
Hi all,
With the new apache cassandra 3.7 version, It is possible to setup a
0]
at org.apache.cassandra.concurrent.SEPWorker.run(SEPWorker.java:105)
[apache-cassandra-3.7.0.jar:3.7.0]
at java.lang.Thread.run(Thread.java:745) [na:1.8.0_73]
==
Thank you.
Kind regar
e,
otherwise my theory is incorrect :)
Cheers,
ml
On Tue, May 24, 2016 at 6:57 AM, Rajesh Radhakrishnan
>
wrote:
Hi Michael,
Thank you for the quick reply.
So you are suggesting to convert this int value(UUID comes back as int via
Spark SQL) to hex?
And selection is just a example to highl
using SPARK SQL
Try converting that int from decimal to hex and inserting dashes in the
appropriate spots - or go the other way.
Also, you are looking at different rows, based upon your selection criteria...
ml
On Tue, May 24, 2016 at 6:23 AM, Rajesh Radhakrishnan
>
wrote:
Hi,
I got a Cassan
Hi,
I got a Cassandra keyspace, but while reading the data(especially UUID) via
Spark SQL using Python is not returning the correct value.
Cassandra:
--
My table 'SAM'' is described below:
CREATE table ks.sam (id uuid, dept text, workflow text, type double primary
key (id, dept))
ne them upfront.
there's no weight to empty columns.
2. if the set of columns is really dynamic, would using 1/more map column(s) be
better?
Avoiding to modify the schema dynamically and avoid concurrent schema changes
is always better.
On Fri, Nov 13, 2015 at 7:40 AM, Rajesh Radhakrishna
are generally a bad idea, especially if they are rapid.
You should rethink your approach.
On Fri, Nov 13, 2015 at 7:20 AM, Rajesh Radhakrishnan
mailto:rajesh.radhakrish...@phe.gov.uk>> wrote:
Thank you Carlos for looking.
But when I rand the nodetool describecluster.
It is showing th
nso>
On 13 November 2015 at 11:14, Rajesh Radhakrishnan
mailto:rajesh.radhakrish...@phe.gov.uk>> wrote:
Hi,
I am using Cassandra 2.1.5 in a cluster of two nodes (running CentOS) and using
Python driver to connect to Cassandra.
My Python code snippet
Hi,
I am using Cassandra 2.1.5 in a cluster of two nodes (running CentOS) and using
Python driver to connect to Cassandra.
My Python code snippet is show here:
#---
import time, os, d
18 matches
Mail list logo