提问者:小点点

在Elasticsearch中使用Java执行Update By Query时NPE


我在Spring Boot应用程序中使用Elasticsearch 2.4,我需要使用JavaAPI执行_update_by_query对远程ES实例的请求。
我已经找到了完成这个任务的方法,但是对于我的情况,我有一个NPE试图执行. get()函数。

ES模块包括:

compile 'org.elasticsearch.module:reindex:2.4.1'

这是我现在用于测试的代码片段:

UpdateByQueryRequestBuilder request = UpdateByQueryAction.INSTANCE.newRequestBuilder(clientWrapper.getClient());  // clientWrapper is a bean and gets injected
Script script = new Script(
  "ctx._source.testName = \"TEST HAPPENED\"",
  ScriptService.ScriptType.INLINE, null, null);

request.source().setTypes("type");

BulkIndexByScrollResponse r = request
  .source(ES_INDEX_NAME)
  .filter(QueryBuilders.termQuery("testId", "Sk9lzQHdJT0"))
  .script(script)
  .get();  // the exception gets raised here

这是一个包装的Clientbean:

@Bean
public ClientWrapper elasticsearchClient(Client client) {
return new ClientWrapper(
  TransportClient.builder()
    .addPlugin(ReindexPlugin.class)  // here's the plugin that is supposed to work
    .settings(client.settings())
    .build());
}

需要包装器来允许通过Spring Boot配置文件进行配置,因此这只是为了方便。

NullPointerException是由调用TransportProxyClient执行(…)方法引起的:

final TransportActionNodeProxy<Request, Response> proxy = proxies.get(action);  // no proxy found here
... 
proxy.execute(node, request, listener);  // NPE here

我想知道我是否错过了一些步骤,或者自从上面提到的问题以来,用法已经改变了?


共1个答案

匿名用户

您缺少传输信息的配置。它应该是TransportClient. builder().addPlugin(ReindexPlugin.class).build().addTransportAddress(new InetSocketTransportAddress(InetAddres.getByName("127.0.0.1"),9300));