Hi,
I was wondering whether it is possible to stop streaming data in from one of
the map operators until some data arrives in the second map operator.
For ex,
if i have ds1.connect(ds2).map(new coflatmapper())
then, i need data to stop flowing from ds1 until some data arrives in ds2.
Is that
Hey everyone,
I'm having an issue using the Flink -> Cassandra connector. The error
message I get is:
*Class com.datastax.driver.core.DefaultResultSetFuture does not implement
the requested interface
org.apache.flink.shaded.com.google.common.util.concurrent.ListenableFuture*
I believe the prob
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
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
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*
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
>
