Hi,
I am using Java 7. The cassandra version I use is actually 2.1.5, not 1.5. Sorry for the confusion. I also tried cassandra 2.1.6, but the problem stays the same. Best regards, Susanne Von: Marcos Ortiz [mailto:mlor...@uci.cu] Gesendet: Freitag, 26. Juni 2015 15:34 An: susanne...@gmx.de Cc: user@cassandra.apache.org Betreff: Re: [MASSMAIL]Cassandra stuck at DataSink running on cluster 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