The problem are the different signatures. The old version seem to take
an `ActionRequest`
whereas the old version requires a `IndexRequest`.
Cheers,
Till
On Tue, Sep 26, 2017 at 10:09 PM, Premkumar, Ramprabhu <
ramprabhu.premku...@verizon.com> wrote:
> Thank you for the response!
>
> It turns out actually that elastic 5.5.1 was throwing that exception but
> when I used the elastic 5.1.1 it works fine.
>
> <dependency>
> <groupId>org.elasticsearch</groupId>
> <artifactId>elasticsearch</artifactId>
> <version>5.1.1</version>
> </dependency>
>
> Like Fabian Hueske mentioned previously it is not working with 5.5.1 and
> probably elastic versions above 5.2
>
> One item which I am still not able to understand is I found the `add`
> method definition in the BulkProcessor class.
>
> public BulkProcessor add(IndexRequest request) {
> return add((DocWriteRequest) request);
> }
>
> Thanks
>
>
>
> On Tue, Sep 26, 2017 at 2:59 AM, Till Rohrmann <trohrm...@apache.org>
> wrote:
>
> > 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
> > > > >
> > > >
> > >
> >
>
