java.lang.NoSuchMethodError: org.elasticsearch.action.bulk.BulkRequest.pipeline()Ljava/lang/String;

Question

I'm using the High Level Rest client from java. Specific version is 6.6.1 against an ES v6.6.1

I'm getting the following error when I try to do a BulkRequest which are all IndexRequests

Happy to file an issue, but was wondering if someone might know what's up in case it's a non issue.

Below is the code I'm using. Would appreciate if anyone knows what this error is.

I'm definitely using lib 6.6.1

compile 'org.elasticsearch.client:elasticsearch-rest-high-level-client:6.6.1'

Thanks

BasicCredentialsProvider credentialsProvider = new BasicCredentialsProvider();
credentialsProvider.setCredentials(AuthScope.ANY, new UsernamePasswordCredentials("elastic", "changeme"));

RestClientBuilder builder = RestClient.builder(new HttpHost("asus.local", 9200))
    .setHttpClientConfigCallback(httpClientBuilder -> httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider));
RestHighLevelClient client = new RestHighLevelClient(builder);
BulkRequest request = new BulkRequest();

String line;
while ((line = reader.readLine()) != null) {
  String[] split = line.split(",");
  Date date = new SimpleDateFormat("yyyy-MM-dd HH:mm").parse(split[0]);
  Map< String, Object> jsonMap = new HashMap< String, Object>();
  jsonMap.put("valuedate", date);
  jsonMap.put("value", Double.valueOf(split[1]));
  IndexRequest indexRequest = new IndexRequest("my_index", "doc", String.valueOf(row))
      .source(jsonMap);
  request.add(indexRequest);
}

System.out.println("starting bulk call");
BulkResponse bulkResponse = client.bulk(request, RequestOptions.DEFAULT);
System.out.println("DONE");

Looks like a discrepancy in versions of elasticsearch used to compile/build project and used to run it — Ivan
– Ivan, Commented Feb 28, 2019 at 20:02
I thought that might be it, so I downloaded ES 6.6.1 before posting. I'm defo on ES 6.6.1 and here is my gradle dependency: compile 'org.elasticsearch.client:elasticsearch-rest-high-level-client:6.6.1' — Java Guy
– Java Guy, Commented Feb 28, 2019 at 20:10
@JavaGuy look at my answer. You need to upgrade the Core library. — LppEdd
– LppEdd, Commented Feb 28, 2019 at 20:11

LppEdd · Accepted Answer · 2019-02-28 20:06:30Z

2

The

public String pipeline() {
    return globalPipeline;
}

method has been added on version 6.6 of the Elasticsearch Server module (GitHub file - 6.6 branch).

Be sure all the Elastic Search modules share the same version.
As you wrote the Rest Client is 6.6.1, I suspect the Server one is older than that (< 6.6).

You need

<dependency>
    <groupId>org.elasticsearch</groupId>
    <artifactId>elasticsearch</artifactId>
    <version>6.6.1</version>
</dependency>

Or for Gradle

implementation 'org.elasticsearch:elasticsearch:6.6.1'

answered Feb 28, 2019 at 20:06

LppEdd

21.3k12 gold badges90 silver badges161 bronze badges

Sign up to request clarification or add additional context in comments.

12 Comments

Java Guy Over a year ago

I was using compile 'org.elasticsearch.client:elasticsearch-rest-high-level-client:6.6.1' . I'll try to add the elasticsearch lib you mentioned thx

LppEdd Over a year ago

@JavaGuy that is another module. The one I posted is the Core one. And look for duplicates inside your "dependencies" block.

Java Guy Over a year ago

yes understood thx. I'm adding both the rest high level client and the core module, correct?

LppEdd Over a year ago

@JavaGuy yes, exactly.

Java Guy Over a year ago

that's it thx. dang - not happy since i wasted a bunch of time on it. it would be reasonable to assume that high rest client 6.6.1 would depend on core 6.6.1 would it not? Other products of ELK stack are all in sync version wise (ES, Kibana, LogStash etc). Thanks for your help

|

Sunny · Accepted Answer · 2019-11-01 06:32:17Z

0

<!-- elasticsearch-rest-high-level-client -->
    <dependency>
        <groupId>org.elasticsearch.client</groupId>
        <artifactId>elasticsearch-rest-high-level-client</artifactId>
        <version>6.6.1</version>
        <exclusions>
            <exclusion>
                <groupId>org.elasticsearch</groupId>
                <artifactId>elasticsearch</artifactId>
            </exclusion>
        </exclusions>
    </dependency>

    <dependency>
        <groupId>org.elasticsearch</groupId>
        <artifactId>elasticsearch</artifactId>
        <version>6.6.1</version>
    </dependency>

I solved this problem use these code.

answered Nov 1, 2019 at 6:32

Sunny

11 bronze badge

Collectives™ on Stack Overflow

java.lang.NoSuchMethodError: org.elasticsearch.action.bulk.BulkRequest.pipeline()Ljava/lang/String;

2 Answers 2

12 Comments

Comments

Your Answer

Linked

Hot Network Questions

Collectives™ on Stack Overflow

2 Answers 2

12 Comments

Comments

Your Answer

Sign up or log in

Post as a guest

Linked

Related