Thanks for the suggestion .. it works now. Also it works cleanly with 1.4.0
(without the hacks) ..
On Wed, Feb 28, 2018 at 7:14 PM, Chesnay Schepler
wrote:
> Well we just ended up in ClassLoader hell...
>
> There are 2 config options that could help:
>
>- add "org.apache.kafka." to "classloa
Well we just ended up in ClassLoader hell...
There are 2 config options that could help:
* add "org.apache.kafka." to "classloader.parent-first-patterns"
o make sure you include the default as well
(|"java.;org.apache.flink.;javax.annotation;org.slf4j;org.apache.log4j;org.apache.lo
Thanks for the suggestion. I copied the application jar to lib. The error
doesn't come but I get another error related to Kafka ..
org.apache.kafka.common.KafkaException: Failed to construct kafka producer
at
org.apache.kafka.clients.producer.KafkaProducer.(KafkaProducer.java:433)
at
org.apache.ka
Hello,
this is probably caused by a known issue in 1.4.1:
https://issues.apache.org/jira/browse/FLINK-8741
This bug is not present in 1.4.0, and it will fixed in 1.4.2 which
should be released within the next days.
As a temporary workaround you can copy your app-assembly-1.0.jar into
the /
Hi -
Facing a ClassNotFoundException while running Flink application that reads
from Kafka. This is a modified version of the NYC Taxi App that reads from
Kafka.
I am using Flink 1.4.1 .. The application runs ok with Flink 1.3 ..
Here's the exception ..
java.lang.ClassNotFoundException:
> com.l
