I strongly disagree with recommending to use version 2.1.x. It only very recently became more or less stable. Anything before 2.1.5 was unusable. You might be better of with a recent 2.0.n version.
Best regards, Nathan On Fri, Jun 26, 2015 at 3:36 PM Marcos Ortiz <mlor...@uci.cu> wrote: > 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 > > > > > >