Regards, Susanne.
Which version of Java are you using here?
Have you tested this with more recent versions of Cassandra?
These new version have a lot of improvements related to SSTable reading
and writing, and much more.
I recommend you that you should use at least a 2.1.x version.
Best,
--
Marcos Ortiz <http://about.me/marcosortiz>, Sr. Product Manager (Data
Infrastructure) at UCI
@marcosluis2186 <http://twitter.com/marcosluis2186>
On 26/06/15 08:21, Susanne Bülow wrote:
Hi,
I am trying to write into Cassandra via the CqlBulkOutputFormat from
an apache flink program. The program succeeds to write into a
cassandra-cluster while the program is running locally on my pc.
However, when trying to run the program on the cluster, it seems to
get stuck at SSTableSimpleUnsortedWriter.put() waiting for the
Diskwriter-Thread, that is not running anymore.
I am using cassandra version 1.5 and apache flink version 0.9.0.
Attached is the full stacktrace.
Thanks in advance,
Susanne
