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 user code jar? On Thu, Feb 9, 2017 at 2:56 PM, Nico <nico.franz...@gmail.com> wrote: > 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.core.Cluster.init(Cluster.java:162) > at com.datastax.driver.core.Cluster.connectAsync(Cluster.java:333) > at com.datastax.driver.core.Cluster.connectAsync(Cluster.java:308) > at com.datastax.driver.core.Cluster.connect(Cluster.java:250) > at org.apache.flink.streaming.connectors.cassandra. > CassandraSinkBase.open(CassandraSinkBase.java:67) > at org.apache.flink.streaming.connectors.cassandra. > CassandraTupleSink.open(CassandraTupleSink.java:42) > at org.apache.flink.api.common.functions.util.FunctionUtils. > openFunction(FunctionUtils.java:36) > at org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator. > open(AbstractUdfStreamOperator.java:112) > at org.apache.flink.streaming.runtime.tasks.StreamTask. > openAllOperators(StreamTask.java:386) > at org.apache.flink.streaming.runtime.tasks.StreamTask. > invoke(StreamTask.java:262) > at org.apache.flink.runtime.taskmanager.Task.run(Task.java:655) > at java.lang.Thread.run(Thread.java:745) > > > So I think the cassandra connector is the reason for it. Moreover, i don't > see a version 1.2 in the maven repository for the connector as mentioned in > the doc. > > <dependency> > <groupId>org.apache.flink</groupId> > <artifactId>flink-connector-cassandra_2.10</artifactId> > <version>1.2.0</version> > </dependency> > > Is there a plan to release a new version? > > Best, > Nico >
