I opened an issue for it: https://issues.apache.org/jira/browse/FLINK-8295
Timo
Am 12/19/17 um 11:14 AM schrieb Nico Kruber:
Hi Dominik,
nice assessment of the issue: in the version of the cassandra-driver we
use there is even a comment about why:
try {
// prevent this string from being
Hi Dominik,
nice assessment of the issue: in the version of the cassandra-driver we
use there is even a comment about why:
try {
// prevent this string from being shaded
Class.forName(String.format("%s.%s.channel.Channel", "io", "netty"));
shaded = false;
} catch (ClassNotFoundException e)
Hi Dominik,
thanks for reporting your issue. I will loop in Chesnay that might know
more about your problem.
There were a lot of dependency changes in 1.4 to make the future more
dependency friendly. Maybe this has not been tested properly.
Regards,
Timo
Am 12/18/17 um 3:07 PM schrieb dom
Hey everyone,
I'm trying to migrate one of my jobs to Flink 1.4 and I'm running into a
classpath/shading error.
What happens is that when Flink calls into Cluster.connect(), somewhere
down in the stream, the cassandra library tries to initialize Netty, and
I'm getting the following exception:
