Hi guys,

I'm working with Kinesis connector and currently trying to solve a
bizarre issue.
I had problems with Kinesis and httpcomponents which I was able to
solve using steps shown in:
https://github.com/apache/flink/pull/4150/commits/9b539470ac308d7af9df9a70792aa1fa8c6995fc

That did the trick and I am able to run my code successfully via
IntelliJ. I am connecting to Kinesis stream hosted on AWS and reading
messages just fine.

Unfortunately that is not true for running Flink via command line
scripts. I get this error when running start-local.sh into flink run
... :
Caused by: java.lang.ClassNotFoundException:
com.fasterxml.jackson.dataformat.cbor.CBORFactory

I have built my Kinesis connector and installed it via mvn install. Am
I missing some steps? I'm assuming that my code is fine given that I'm
able to run it through IntelliJ.

Anyone faced this problem or maybe some solution comes to your mind?

Cheers
Tomasz

Reply via email to