0ct0pu5/fess
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

elasticsearch 6.5.0

Browse source
This commit is contained in:
Shinsuke Sugaya 2018-11-17 14:05:12 +09:00
parent 2e2ca68749
commit 3f9aa4f5c7
5 changed files with 38 additions and 41 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
dbflute.xml
View file

@ -2,7 +2,7 @@
<project name="dbflute" basedir=".">
<property name="mydbflute.dir" value="${basedir}/mydbflute" />
<property name="target.dir" value="${basedir}/target" />
<property name="branch.name" value="es-6.4" />
<property name="branch.name" value="es-6.5" />
<property name="mydbflute.url" value="https://github.com/lastaflute/lastaflute-example-waterfront/archive/${branch.name}.zip" />
<target name="mydbflute.check">

42
plugin.xml
View file

@ -13,66 +13,66 @@
<mkdir dir="${plugins.dir}" />
<!-- analysis-extension -->
<antcall target="install.plugin">
<param name="repo.url" value="${maven.release.repo.url}" />
<param name="repo.url" value="${maven.snapshot.repo.url}" />
<param name="plugin.groupId" value="org/codelibs" />
<param name="plugin.name.prefix" value="elasticsearch-" />
<param name="plugin.name" value="analysis-extension" />
<param name="plugin.version" value="6.4.0" />
<param name="plugin.zip.version" value="6.4.0" />
<param name="plugin.version" value="6.5.0-SNAPSHOT" />
<param name="plugin.zip.version" value="6.5.0-20181115.212551-2" />
</antcall>
<!-- analysis-fess -->
<antcall target="install.plugin">
<param name="repo.url" value="${maven.release.repo.url}" />
<param name="repo.url" value="${maven.snapshot.repo.url}" />
<param name="plugin.groupId" value="org/codelibs" />
<param name="plugin.name.prefix" value="elasticsearch-" />
<param name="plugin.name" value="analysis-fess" />
<param name="plugin.version" value="6.4.0" />
<param name="plugin.zip.version" value="6.4.0" />
<param name="plugin.version" value="6.5.0-SNAPSHOT" />
<param name="plugin.zip.version" value="6.5.0-20181115.212746-1" />
</antcall>
<!-- configsync -->
<antcall target="install.plugin">
<param name="repo.url" value="${maven.release.repo.url}" />
<param name="repo.url" value="${maven.snapshot.repo.url}" />
<param name="plugin.groupId" value="org/codelibs" />
<param name="plugin.name.prefix" value="elasticsearch-" />
<param name="plugin.name" value="configsync" />
<param name="plugin.version" value="6.4.0" />
<param name="plugin.zip.version" value="6.4.0" />
<param name="plugin.version" value="6.5.0-SNAPSHOT" />
<param name="plugin.zip.version" value="6.5.0-20181115.133917-1" />
</antcall>
<!-- dataformat -->
<antcall target="install.plugin">
<param name="repo.url" value="${maven.release.repo.url}" />
<param name="repo.url" value="${maven.snapshot.repo.url}" />
<param name="plugin.groupId" value="org/codelibs" />
<param name="plugin.name.prefix" value="elasticsearch-" />
<param name="plugin.name" value="dataformat" />
<param name="plugin.version" value="6.4.0" />
<param name="plugin.zip.version" value="6.4.0" />
<param name="plugin.version" value="6.5.0-SNAPSHOT" />
<param name="plugin.zip.version" value="6.5.0-20181115.134048-1" />
</antcall>
<!-- langfield -->
<antcall target="install.plugin">
<param name="repo.url" value="${maven.release.repo.url}" />
<param name="repo.url" value="${maven.snapshot.repo.url}" />
<param name="plugin.groupId" value="org/codelibs" />
<param name="plugin.name.prefix" value="elasticsearch-" />
<param name="plugin.name" value="langfield" />
<param name="plugin.version" value="6.4.1" />
<param name="plugin.zip.version" value="6.4.1" />
<param name="plugin.version" value="6.5.0-SNAPSHOT" />
<param name="plugin.zip.version" value="6.5.0-20181116.132224-1" />
</antcall>
<!-- learning-to-rank -->
<antcall target="install.plugin">
<param name="repo.url" value="${maven.release.repo.url}" />
<param name="repo.url" value="${maven.snapshot.repo.url}" />
<param name="plugin.groupId" value="org/codelibs" />
<param name="plugin.name.prefix" value="elasticsearch-" />
<param name="plugin.name" value="learning-to-rank" />
<param name="plugin.version" value="6.4.0" />
<param name="plugin.zip.version" value="6.4.0" />
<param name="plugin.version" value="6.5.0-SNAPSHOT" />
<param name="plugin.zip.version" value="6.5.0-20181117.042241-1" />
</antcall>
<!-- minhash -->
<antcall target="install.plugin">
<param name="repo.url" value="${maven.release.repo.url}" />
<param name="repo.url" value="${maven.snapshot.repo.url}" />
<param name="plugin.groupId" value="org/codelibs" />
<param name="plugin.name.prefix" value="elasticsearch-" />
<param name="plugin.name" value="minhash" />
<param name="plugin.version" value="6.4.0" />
<param name="plugin.zip.version" value="6.4.0" />
<param name="plugin.version" value="6.5.0-SNAPSHOT" />
<param name="plugin.zip.version" value="6.5.0-20181115.134303-1" />
</antcall>
<antcall target="remove.jars" />

6
pom.xml
View file

@ -63,11 +63,11 @@
<crawler.version>3.0.0-SNAPSHOT</crawler.version>
<!-- Suggest -->
<suggest.version>6.4.3-SNAPSHOT</suggest.version>
<suggest.version>6.5.0-SNAPSHOT</suggest.version>
<!-- Elasticsearch -->
<elasticsearch.version>6.4.3</elasticsearch.version>
<elasticsearch.httpclient.version>6.4.0-SNAPSHOT</elasticsearch.httpclient.version>
<elasticsearch.version>6.5.0</elasticsearch.version>
<elasticsearch.httpclient.version>6.5.0-SNAPSHOT</elasticsearch.httpclient.version>
<cluster.runner.version>${elasticsearch.version}.0</cluster.runner.version>
<!-- Tomcat -->

11
src/main/java/org/codelibs/fess/es/client/FessEsClient.java
View file

@ -76,13 +76,11 @@ import org.elasticsearch.action.DocWriteRequest.OpType;
import org.elasticsearch.action.DocWriteResponse.Result;
import org.elasticsearch.action.admin.cluster.health.ClusterHealthResponse;
import org.elasticsearch.action.admin.indices.alias.IndicesAliasesRequestBuilder;
import org.elasticsearch.action.admin.indices.alias.IndicesAliasesResponse;
import org.elasticsearch.action.admin.indices.create.CreateIndexResponse;
import org.elasticsearch.action.admin.indices.exists.indices.IndicesExistsResponse;
import org.elasticsearch.action.admin.indices.flush.FlushResponse;
import org.elasticsearch.action.admin.indices.get.GetIndexResponse;
import org.elasticsearch.action.admin.indices.mapping.get.GetMappingsResponse;
import org.elasticsearch.action.admin.indices.mapping.put.PutMappingResponse;
import org.elasticsearch.action.admin.indices.refresh.RefreshResponse;
import org.elasticsearch.action.bulk.BulkItemResponse;
import org.elasticsearch.action.bulk.BulkItemResponse.Failure;
@ -120,6 +118,7 @@ import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.action.search.SearchScrollRequest;
import org.elasticsearch.action.search.SearchScrollRequestBuilder;
import org.elasticsearch.action.support.WriteRequest.RefreshPolicy;
import org.elasticsearch.action.support.master.AcknowledgedResponse;
import org.elasticsearch.action.termvectors.MultiTermVectorsRequest;
import org.elasticsearch.action.termvectors.MultiTermVectorsRequestBuilder;
import org.elasticsearch.action.termvectors.MultiTermVectorsResponse;
@ -407,7 +406,7 @@ public class FessEsClient implements Client {
logger.warn(mappingFile + " is not found.", e);
}
try {
final PutMappingResponse putMappingResponse =
final AcknowledgedResponse putMappingResponse =
client.admin().indices().preparePutMapping(indexName).setType(docType).setSource(source, XContentType.JSON)
.execute().actionGet(fessConfig.getIndexIndicesTimeout());
if (putMappingResponse.isAcknowledged()) {
@ -447,7 +446,7 @@ public class FessEsClient implements Client {
for (final String index : searchIndices) {
builder.removeAlias(index, searchAlias);
}
final IndicesAliasesResponse response = builder.execute().actionGet(fessConfig.getIndexIndicesTimeout());
final AcknowledgedResponse response = builder.execute().actionGet(fessConfig.getIndexIndicesTimeout());
return response.isAcknowledged();
}
@ -465,7 +464,7 @@ public class FessEsClient implements Client {
if (source.trim().equals("{}")) {
source = null;
}
final IndicesAliasesResponse response =
final AcknowledgedResponse response =
client.admin().indices().prepareAliases().addAlias(createdIndexName, aliasName, source).execute()
.actionGet(fessConfig.getIndexIndicesTimeout());
if (response.isAcknowledged()) {
@ -914,7 +913,7 @@ public class FessEsClient implements Client {
if (response.hasFailures()) {
if (logger.isDebugEnabled()) {
@SuppressWarnings("rawtypes")
final List<DocWriteRequest> requests = bulkRequestBuilder.request().requests();
final List<DocWriteRequest<?>> requests = bulkRequestBuilder.request().requests();
final BulkItemResponse[] items = response.getItems();
if (requests.size() == items.length) {
for (int i = 0; i < requests.size(); i++) {

18
src/main/java/org/codelibs/fess/util/UpgradeUtil.java
View file

@ -23,15 +23,13 @@ import org.codelibs.core.io.FileUtil;
import org.codelibs.curl.CurlResponse;
import org.codelibs.fess.mylasta.direction.FessConfig;
import org.elasticsearch.action.ActionListener;
import org.elasticsearch.action.admin.indices.alias.IndicesAliasesResponse;
import org.elasticsearch.action.admin.indices.delete.DeleteIndexResponse;
import org.elasticsearch.action.admin.indices.exists.indices.IndicesExistsResponse;
import org.elasticsearch.action.admin.indices.mapping.get.GetFieldMappingsResponse;
import org.elasticsearch.action.admin.indices.mapping.get.GetFieldMappingsResponse.FieldMappingMetaData;
import org.elasticsearch.action.admin.indices.mapping.get.GetMappingsResponse;
import org.elasticsearch.action.admin.indices.mapping.put.PutMappingRequestBuilder;
import org.elasticsearch.action.admin.indices.mapping.put.PutMappingResponse;
import org.elasticsearch.action.index.IndexRequest;
import org.elasticsearch.action.support.master.AcknowledgedResponse;
import org.elasticsearch.client.Client;
import org.elasticsearch.client.IndicesAdminClient;
import org.elasticsearch.cluster.metadata.MappingMetaData;
@ -72,7 +70,7 @@ public final class UpgradeUtil {
final File aliasConfigFile = org.codelibs.core.io.ResourceUtil.getResourceAsFile(aliasConfigPath);
if (aliasConfigFile.exists()) {
final String source = FileUtil.readUTF8(aliasConfigFile);
final IndicesAliasesResponse response =
final AcknowledgedResponse response =
indicesClient.prepareAliases().addAlias(indexName, aliasName, source).execute()
.actionGet(fessConfig.getIndexIndicesTimeout());
if (response.isAcknowledged()) {
@ -105,7 +103,7 @@ public final class UpgradeUtil {
logger.warn(mappingFile + " is not found.", e);
}
try {
final PutMappingResponse putMappingResponse =
final AcknowledgedResponse putMappingResponse =
indicesClient.preparePutMapping(index).setType(type).setSource(source, XContentType.JSON).execute()
.actionGet(fessConfig.getIndexIndicesTimeout());
if (putMappingResponse.isAcknowledged()) {
@ -129,7 +127,7 @@ public final class UpgradeUtil {
final FieldMappingMetaData fieldMappings = gfmResponse.fieldMappings(index, type, field);
if (fieldMappings == null || fieldMappings.isNull()) {
try {
final PutMappingResponse pmResponse =
final AcknowledgedResponse pmResponse =
indicesClient.preparePutMapping(index).setType(type).setSource(source, XContentType.JSON).execute().actionGet();
if (!pmResponse.isAcknowledged()) {
logger.warn("Failed to add " + field + " to " + index + "/" + type);
@ -153,7 +151,7 @@ public final class UpgradeUtil {
if (type != null) {
builder.setType(type);
}
final PutMappingResponse pmResponse = builder.execute().actionGet();
final AcknowledgedResponse pmResponse = builder.execute().actionGet();
if (!pmResponse.isAcknowledged()) {
logger.warn("Failed to update " + index + " settings.");
} else {
@ -191,11 +189,11 @@ public final class UpgradeUtil {
return false;
}
public static void deleteIndex(final IndicesAdminClient indicesClient, final String index, final Consumer<DeleteIndexResponse> comsumer) {
indicesClient.prepareDelete(index).execute(new ActionListener<DeleteIndexResponse>() {
public static void deleteIndex(final IndicesAdminClient indicesClient, final String index, final Consumer<AcknowledgedResponse> comsumer) {
indicesClient.prepareDelete(index).execute(new ActionListener<AcknowledgedResponse>() {
@Override
public void onResponse(final DeleteIndexResponse response) {
public void onResponse(final AcknowledgedResponse response) {
logger.info("Deleted " + index + " index.");
comsumer.accept(response);
}