Re: Cassandra Connector Problem (Possible Guava Conflict?)

Hi, I have the same problem but trying your solution so substituting this: org.apache.maven.plugins maven-shade-plugin 2.4.1

Re: Cassandra connector POJO - tombstone question

No problem :) Thanks for letting me know. Best, Tarandeep On Thu, Jun 1, 2017 at 11:18 AM, Chesnay Schepler wrote: > No, unfortunately I forgot about them :/ > > > On 01.06.2017 19:39, Tarandeep Singh wrote: > > Hi Chesnay, > > Did your code changes (exposing mapper options) made it in 1.3 rele

Re: Cassandra connector POJO - tombstone question

No, unfortunately I forgot about them :/ On 01.06.2017 19:39, Tarandeep Singh wrote: Hi Chesnay, Did your code changes (exposing mapper options) made it in 1.3 release? Thank you, Tarandeep On Wed, Apr 12, 2017 at 2:34 PM, Tarandeep Singh > wrote: Thanks Ches

Re: Cassandra connector POJO - tombstone question

Hi Chesnay, Did your code changes (exposing mapper options) made it in 1.3 release? Thank you, Tarandeep On Wed, Apr 12, 2017 at 2:34 PM, Tarandeep Singh wrote: > Thanks Chesnay, this will work. > > Best, > Tarandeep > > On Wed, Apr 12, 2017 at 2:42 AM, Chesnay Schepler > wrote: > >> Hello, >

Re: Cassandra connector POJO - tombstone question

Thanks Chesnay, this will work. Best, Tarandeep On Wed, Apr 12, 2017 at 2:42 AM, Chesnay Schepler wrote: > Hello, > > what i can do is add hook like we do for the ClusterBuilder with which you > can provide a set of options that will > be used for every call to the mapper. This would provide yo

Re: Cassandra connector POJO - tombstone question

Hello, what i can do is add hook like we do for the ClusterBuilder with which you can provide a set of options that will be used for every call to the mapper. This would provide you access with all options that are listed on the page you linked. You can find an implementation of this here: h

Re: Cassandra Connector

Hey Chesnay, that looks good. I like to use the same mechanism for all my sinks. Thus, this > readings.addSink(new CassandraTupleSink(, ); will be my desired way. best, Stephan > On 22 Nov 2016, at 09:33, Chesnay Schepler wrote: > > Actually this is a bit inaccurate. _Some_ implementations

Re: Cassandra Connector

Actually this is a bit inaccurate. _Some_ implementations are not implemented as a sink. Also, you can in fact instantiate the sinks yourself as well, as in readings.addSink(new CassandraTupleSink(, ); On 22.11.2016 09:30, Chesnay Schepler wrote: Hello, the CassandraSink is not implement

Re: Cassandra Connector

Hello, the CassandraSink is not implemented as a sink but as a special operator, so you wouldn't be able to use the addSink() method. (I can't remember the actual method being used.) There are also several different implementations for various types (tuples, pojo's, scala case classes) but we

Re: Cassandra Connector Problem (Possible Guava Conflict?)

Perfect, that worked. Thanks! On Sun, Jun 26, 2016 at 12:56 PM, Chesnay Schepler wrote: > Replace the maven shade plugin section in the flink-cassandra pom with the > following, > or apply the additions(in bold) manually: > > > org.apache.maven.plugins >

Re: Cassandra Connector Problem (Possible Guava Conflict?)

Replace the maven shade plugin section in the flink-cassandra pom with the following, or apply the additions(in bold) manually: org.apache.maven.plugins maven-shade-plugin 2.4.1 *shade-flink*

Re: Cassandra Connector Problem (Possible Guava Conflict?)

Hey Chesnay, Thanks for the response. Is there anything I can do in the short term to skirt the issue? On Sun, Jun 26, 2016 at 11:55 AM, Chesnay Schepler wrote: > The problem is that the cassandra jar currently contains 2 shaded guavas. > I already have a fix ready that suppressed the root-pom

Re: Cassandra Connector Problem (Possible Guava Conflict?)

The problem is that the cassandra jar currently contains 2 shaded guavas. I already have a fix ready that suppressed the root-poms shade plugin configuration inside the cassandra submit. I will submit that next week. On 26.06.2016 17:46, Eamon Kavanagh wrote: Hey everyone, I'm having an issu