Mailing-List: contact user-help@flink.apache.org; run by ezmlm
Precedence: bulk
MIME-Version: 1.0
In-Reply-To: <20171117132211.0e304a143717be2628beec81@wegtam.com>
References: <20171117132211.0e304a143717be2628beec81@wegtam.com>
From: Fabian Hueske <fhueske@gmail.com>
Date: Fri, 24 Nov 2017 11:56:53 +0100
Message-ID: <CAAdrtT0Li6ZWFm1yHb2w_5koij5NAiVdYFy437obmVj+NCskYQ@mail.gmail.com>
Subject: Re: Accessing Cassandra for reading and writing
To: =?UTF-8?B?QW5kcsOpIFNjaMO8dHo=?= <andre@wegtam.com>
Cc: user <user@flink.apache.org>
Content-Type: multipart/alternative; boundary="001a1145ab00799e47055eb86b5e"
archived-at: Fri, 24 Nov 2017 10:57:45 -0000

--001a1145ab00799e47055eb86b5e
Content-Type: text/plain; charset="UTF-8"
Content-Transfer-Encoding: quoted-printable

Hi Andre,

Do you have a batch or streaming use case?
Flink provides Cassandra Input and OutputFormats for DataSet (batch) jobs
and a Cassandra Sink for DataStream applications. The is no Cassandra
source for DataStream applications.

Regarding your error, this looks more like a Zepplin configuration issue to
me.
It seems that the JAR file is not correctly added to the classpath.

Best,
Fabian

2017-11-17 13:22 GMT+01:00 Andr=C3=A9 Sch=C3=BCtz <andre@wegtam.com>:

> Hi,
>
> we want to read and write from and to Cassandra.
>
> We found the Flink-Cassandra connector and added the JAR to the lib
> folder of the running Flink cluster (local machine).
>
> Trying to access the Cassandra database by adding the import
> to a notebook within Apache Zeppelin, resulted in the following error:
>
> import org.apache.flink.streaming.connectors.cassandra._
>
> error: object connectors is not a member of package
> org.apache.flink.streaming
> import org.apache.flink.streaming.connectors.cassandra._
>
> We have Flink 1.3.2 running.
>
> It would be great to see an example of what to implement for reading
> from Cassandra and another that uses the Cassandra Connector sink (the
> example from the documentation gave us the error above).
> We tried to find something but had no luck.
>
> Kind regards,
> Andre
>

--001a1145ab00799e47055eb86b5e
Content-Type: text/html; charset="UTF-8"
Content-Transfer-Encoding: quoted-printable

<div dir=3D"ltr"><div><div>Hi Andre,</div><div><br></div><div>Do you have a=
 batch or streaming use case?</div>Flink provides Cassandra Input and Outpu=
tFormats for DataSet (batch) jobs and a Cassandra Sink for DataStream appli=
cations. The is no Cassandra source for DataStream applications.</div><div>=
<br></div><div>Regarding your error, this looks more like a Zepplin configu=
ration issue to me.</div><div>It seems that the JAR file is not correctly a=
dded to the classpath.</div><div><br></div><div>Best,</div><div>Fabian<br><=
/div></div><div class=3D"gmail_extra"><br><div class=3D"gmail_quote">2017-1=
1-17 13:22 GMT+01:00 Andr=C3=A9 Sch=C3=BCtz <span dir=3D"ltr">&lt;<a href=
=3D"mailto:andre@wegtam.com" target=3D"_blank">andre@wegtam.com</a>&gt;</sp=
an>:<br><blockquote class=3D"gmail_quote" style=3D"margin:0 0 0 .8ex;border=
-left:1px #ccc solid;padding-left:1ex">Hi,<br>
<br>
we want to read and write from and to Cassandra.<br>
<br>
We found the Flink-Cassandra connector and added the JAR to the lib<br>
folder of the running Flink cluster (local machine).<br>
<br>
Trying to access the Cassandra database by adding the import<br>
to a notebook within Apache Zeppelin, resulted in the following error:<br>
<br>
import org.apache.flink.streaming.<wbr>connectors.cassandra._<br>
<br>
error: object connectors is not a member of package org.apache.flink.stream=
ing<br>
import org.apache.flink.streaming.<wbr>connectors.cassandra._<br>
<br>
We have Flink 1.3.2 running.<br>
<br>
It would be great to see an example of what to implement for reading<br>
from Cassandra and another that uses the Cassandra Connector sink (the<br>
example from the documentation gave us the error above).<br>
We tried to find something but had no luck.<br>
<br>
Kind regards,<br>
Andre<br>
</blockquote></div><br></div>

--001a1145ab00799e47055eb86b5e--