Re: Flink 1.2 and Cassandra Connector

2017-03-16 Thread Robert Metzger
I've created a pull request for the fix: https://github.com/apache/flink/pull/3556 It would be nice if one of the issue reporters could validate that the cassandra connector works after the fix. If it is a valid fix, I would like to include it into the upcoming 1.2.1 release. On Thu, Mar 16, 2017

Re: Flink 1.2 and Cassandra Connector

2017-03-16 Thread Robert Metzger
Yep, this is definitively a bug / misconfiguration in the build system. The cassandra client defines metrics-core as a dependency, but the shading is dropping the dependency when building the dependency reduced pom. To resolve the issue, we need to add the following line into the shading config of

Re: Flink 1.2 and Cassandra Connector

2017-03-16 Thread Stephan Ewen
Can we improve the Flink experience here by adding this dependency directly to the cassandra connector pom.xml (so that user jars always pull it in via transitivity)? On Wed, Mar 15, 2017 at 4:09 PM, Nico wrote: > Hi @all, > > I came back to this issue today... > > @Robert: > "com/codahale/metri

Re: Flink 1.2 and Cassandra Connector

2017-03-15 Thread Nico
Hi @all, I came back to this issue today... @Robert: "com/codahale/metrics/Metric" class was not available in the user code jar Even after adding the metric class into the build-jar profile of the pom file, more "class not found" errors occur. So the only solution was to add the whole dependency

Re: Flink 1.2 and Cassandra Connector

2017-03-06 Thread Chesnay Schepler
Hello, i believe the cassandra connector is not shading it's dependencies properly. This didn't cause issues in the past since flink used to have a dependency on codahale metrics as well. Please open a JIRA for this issue. Regards, Chesnay On 06.03.2017 11:32, Tarandeep Singh wrote: Hi Robe

Re: Flink 1.2 and Cassandra Connector

2017-03-06 Thread Tarandeep Singh
Hi Robert & Nico, I am facing the same problem (java.lang.NoClassDefFoundError: com/codahale/metrics/Metric) Can you help me identify shading issue in pom.xml file. My pom.xml content- - http://maven.apache.org/POM/4.0.0"; xmlns:xsi="http://www.w3.org

Re: Flink 1.2 and Cassandra Connector

2017-02-12 Thread Robert Metzger
Hi Nico, The cassandra connector should be available on Maven central: http://search.maven.org/#artifactdetails%7Corg.apache.flink%7Cflink-connector-cassandra_2.10%7C1.2.0%7Cjar Potentially, the issue you've mentioned is due to some shading issue. Is the "com/codahale/metrics/Metric" class in your

Flink 1.2 and Cassandra Connector

2017-02-09 Thread Nico
Hi, I would like to upgrade to the new stable version 1.2 - but i get an ClassNotFound exception when i start the application. Caused by: java.lang.NoClassDefFoundError: com/codahale/metrics/Metric at com.datastax.driver.core.Cluster$Manager.init(Cluster.java:1367) at com.datastax.driver.