flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Till Rohrmann <trohrm...@apache.org>
Subject Re: NoClassDefFoundError on cluster with httpclient 4.5.2
Date Thu, 20 Oct 2016 09:05:07 GMT
Hi Yassine,

can you check whether the httpclient jar is contained in your job jar which
you submit to the cluster?

Cheers,
Till

On Wed, Oct 19, 2016 at 6:41 PM, Yassine MARZOUGUI <
y.marzougui@mindlytix.com> wrote:

> Hi all,
>
> I'm using httpclient with the following dependency:
>
> <dependency>
> <groupId>org.apache.httpcomponents</groupId>
> <artifactId>httpclient</artifactId>
> <version>4.5.2</version>
> </dependency>
>
> On local mode, the program works correctly, but when executed on the
> cluster, I get the following exception:
>
> java.lang.Exception: The user defined 'open(Configuration)' method in
> class org.myorg.quickstart.Frequencies$2 caused an exception: Could not
> initialize class org.apache.http.conn.ssl.SSLConnectionSocketFactory
>         at org.apache.flink.runtime.operators.BatchTask.
> openUserCode(BatchTask.java:1337)
>         at org.apache.flink.runtime.operators.chaining.
> ChainedFlatMapDriver.openTask(ChainedFlatMapDriver.java:47)
>         at org.apache.flink.runtime.operators.BatchTask.
> openChainedTasks(BatchTask.java:1377)
>         at org.apache.flink.runtime.operators.DataSourceTask.
> invoke(DataSourceTask.java:124)
>         at org.apache.flink.runtime.taskmanager.Task.run(Task.java:585)
>         at java.lang.Thread.run(Unknown Source)
> Caused by: java.lang.NoClassDefFoundError: Could not initialize class
> org.apache.http.conn.ssl.SSLConnectionSocketFactory
>         at org.apache.http.impl.client.HttpClientBuilder.build(
> HttpClientBuilder.java:966)
>         at org.myorg.quickstart.Frequencies$2.open(Frequencies.java:82)
>         at org.apache.flink.api.common.functions.util.FunctionUtils.
> openFunction(FunctionUtils.java:38)
>         at org.apache.flink.runtime.operators.BatchTask.
> openUserCode(BatchTask.java:1335)
>         ... 5 more
>
> I'm using Flink 1.1.3. Any idea how to solve the problem? Thank you.
>
> Best,
> Yassine
>

Mime
View raw message