Hi,
usually such an error indicates that you have a different version of
Elasticsearch in your classpath than the one used at compile time.
Please make sure that you don't have accidentally an older version of
Elasticsearch in your classpath. You can see the complete classpath at the
beginning of the logs.
If this is not the case, then please check that the right version is
included in the Flink jar by checking whether the above-mentioned method is
contained in the class file via `jad`.
Cheers,
Till
On Tue, Sep 26, 2017 at 12:37 AM, Premkumar, Ramprabhu <
ramprabhu.premku...@verizon.com> wrote:
> 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
> > >
> >
>
