[ 
https://issues.apache.org/jira/browse/FLINK-8658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16364597#comment-16364597
 ] 

Ken Krugler commented on FLINK-8658:
------------------------------------

Hi [~sathyadev] - if you're sure this is a Flink bug, then opening a Jira is 
fine. But if it's not yet clear where the problem lies, you should first write 
to the user mailing list, and request input from the community. If that's the 
case, please close this issue and send the email, thanks.

> NoClassDefFoundError: Could not initialize class 
> org.elasticsearch.transport.client.PreBuiltTransportClient
> -----------------------------------------------------------------------------------------------------------
>
>                 Key: FLINK-8658
>                 URL: https://issues.apache.org/jira/browse/FLINK-8658
>             Project: Flink
>          Issue Type: Bug
>          Components: ElasticSearch Connector
>    Affects Versions: 1.4.0
>         Environment: Flink 1.4.0 , Easticsearch 5.1.1, Scala 2.11.0, kafka 
> 0.10.0, Ubuntu 17.04.
>  
>  
>            Reporter: sathiyarajan
>            Priority: Major
>              Labels: features
>   Original Estimate: 4m
>  Remaining Estimate: 4m
>
>  
> NoClassDefFoundError: Could not initialize class 
> org.elasticsearch.transport.client.PreBuiltTransportClient is displayed while 
> running flink 1.4.0 with Elasticsearch 5.1.1 .
>  
> Note: In IntellIj SBT its working fine but while deplying the same jar in 
> flink1.4.0 
> Stack Trace:
> NoClassDefFoundError: Could not initialize class 
> org.elasticsearch.transport.client.PreBuiltTransportClient at
>  
> org.apache.flink.streaming.connectors.elasticsearch5.Elasticsearch5ApiCallBridge.createClient(Elasticsearch5ApiCallBridge.java:73)
> at 
> org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase.open(ElasticsearchSinkBase.java:281)
> at 
> org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:36)
> at 
> org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:102)
> at 
> org.apache.flink.streaming.api.operators.StreamSink.open(StreamSink.java:48)
> at 
> org.apache.flink.streaming.runtime.tasks.StreamTask.openAllOperators(StreamTask.java:393)
> at 
> org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:254)
> at org.apache.flink.runtime.taskmanager.Task.run(Task.java:718)
> at java.lang.Thread.run(Thread.java:748)



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Reply via email to