Cannot load user classes

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

Cannot load user classes

Soheil Pourbafrani
Hey, I wrote a code using Flink and creating fat jar using maven, I can errorlessly run it on a remote cluster. Trying to run it without creating a fat jar and directly from IDE I got the errorĀ Cannot load user class for not Flink core classes. For example `Cannot load user class: org.apache.flink.streaming.connectors.fs.bucketing.BucketingSink` or `Kafkaconnector things`. If I pass local jar files in CreateRemoteEnvirnment method its ok but passing all extra jar files is not the standard way and is time-consuming. I wish I could run Flink codes directly in IDE without creating maven fat jars. Is there any way to do that?
Reply | Threaded
Open this post in threaded view
|

Re: Cannot load user classes

Chesnay Schepler
Can you show us the dependency section of your pom?

On 13.12.2017 08:25, Soheil Pourbafrani wrote:
Hey, I wrote a code using Flink and creating fat jar using maven, I can errorlessly run it on a remote cluster. Trying to run it without creating a fat jar and directly from IDE I got the errorĀ Cannot load user class for not Flink core classes. For example `Cannot load user class: org.apache.flink.streaming.connectors.fs.bucketing.BucketingSink` or `Kafkaconnector things`. If I pass local jar files in CreateRemoteEnvirnment method its ok but passing all extra jar files is not the standard way and is time-consuming. I wish I could run Flink codes directly in IDE without creating maven fat jars. Is there any way to do that?