Hi,
Receiving this exception with the 1.3.2 dependencies for elastic search
connector.
java.lang.NoSuchMethodError:
org.elasticsearch.action.bulk.BulkProcessor.add(Lorg/elasticsearch/action/ActionRequest;)Lorg/elasticsearch/action/bulk/BulkProcessor;
at
org.apache.flink.streaming.connectors.elasticsearch.BulkProcessorIndexer.add(BulkProcessorIndexer.java:52)
But the I see this in the code base in BulkProcessor Class
public BulkProcessor add(IndexRequest request) {
return add((DocWriteRequest) request);
}
Could you please help in letting me know why is this exception being thrown
despite the method definition existing ?
Dependencies used :
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-connector-elasticsearch5_2.11</artifactId>
<version>1.3.2</version>
<exclusions>
<exclusion>
<groupId>org.elasticsearch.client</groupId>
<artifactId>transport</artifactId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>org.elasticsearch.client</groupId>
<artifactId>x-pack-transport</artifactId>
<version>5.5.1</version>
</dependency>
Thanks
On Tue, Sep 19, 2017 at 3:42 AM, Fabian Hueske <fhue...@gmail.com> wrote:
> Hi,
>
> that's correct. Elasticsearch changed its API from 5.1 to 5.2.
> There is a JIRA issue for the problem [1] and a pull request [2].
>
> It would be great if you could help to resolve the problem by verifying the
> PR.
>
> Thanks, Fabian
>
> [1] https://urldefense.proofpoint.com/v2/url?u=https-3A__issues.
> apache.org_jira_browse_FLINK-2D7386&d=DwIBaQ&c=
> udBTRvFvXC5Dhqg7UHpJlPps3mZ3LRxpb6__0PomBTQ&r=B-nyt4heL8e6bDgEOtGErOdVe8e-
> DMB2iPYpRfqRe-A&m=TAQ1vm3DOiBGJpe-EfbNyMVcz8zx5EYiGxx4kX4-BRo&s=
> cq_sXWcRAEv-wXNoxdNa-IMc_-Kf4rCHK1xsW4Dn8uk&e=
> [2] https://urldefense.proofpoint.com/v2/url?u=https-3A__github.
> com_apache_flink_pull_4675&d=DwIBaQ&c=udBTRvFvXC5Dhqg7UHpJlPps3mZ3LR
> xpb6__0PomBTQ&r=B-nyt4heL8e6bDgEOtGErOdVe8e-DMB2iPYpRfqRe-A&m=
> TAQ1vm3DOiBGJpe-EfbNyMVcz8zx5EYiGxx4kX4-BRo&s=X13U81ugZMK53oPA-
> Gk3CLvP0rzFr2Xi2ix1UgoqzBc&e=
>
> 2017-09-15 19:05 GMT+02:00 Premkumar, Ramprabhu <
> ramprabhu.premku...@verizon.com>:
>
> > Hi Team,
> >
> > Could you please let me know if the elasticsearch connector from Flink
> > 1.3.2 support elasticsearch 5.5.1. I am not able to find the add method
> in
> > RequestIndexer interface using this connector.
> >
> > Dependency used:
> >
> > <dependency>
> > <groupId>org.apache.flink</groupId>
> > <artifactId>flink-connector-elasticsearch5_2.10</artifactId>
> > <version>1.3.2</version>
> > </dependency>
> >
> > Thanks
> > Ramprabhu Premkumar
> >
>
