You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@cassandra.apache.org by Marcos Ortiz <ml...@uci.cu> on 2015/06/26 15:34:12 UTC
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
>
Re: Cassandra stuck at DataSink running on cluster
Posted by Nathan Bijnens <na...@nathan.gs>.
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 <ml...@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
>
>
>
>
>
>
AW: [MASSMAIL]Cassandra stuck at DataSink running on cluster
Posted by Susanne Bülow <su...@gmx.de>.
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:mlortiz@uci.cu]
Gesendet: Freitag, 26. Juni 2015 15:34
An: susanne.90@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