- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for buildFailureMessage (0.07 sec)
-
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/AbstractCrawlerService.java
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Thu Aug 07 02:55:08 UTC 2025 - 34.2K bytes - Viewed (0) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueService.java
} return builder.execute(); }); if (bulkResponse.hasFailures()) { throw new OpenSearchAccessException(bulkResponse.buildFailureMessage()); } final String sid = scrollId; response = getClient().get(c -> c.prepareSearchScroll(sid).setScroll(new TimeValue(scrollTimeout)).execute());
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Thu Aug 07 02:55:08 UTC 2025 - 17K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/score/ScoreBooster.java
final BulkResponse response = bulkRequestBuilder.execute().actionGet(requestTimeout); if (response.hasFailures()) { logger.warn("Failed to update scores: {}", response.buildFailureMessage()); } bulkRequestBuilder = null; } } /** * Gets the priority of this score booster. * @return The priority. */
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 6.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/opensearch/config/allcommon/EsAbstractBehavior.java
final BulkResponse bulkResponse = bulkRequest.execute().actionGet(bulkTimeout); if (bulkResponse.hasFailures()) { throw new IllegalBehaviorStateException(bulkResponse.buildFailureMessage()); } response = client.prepareSearchScroll(scrollId).setScroll(scrollForDelete).execute().actionGet(scrollSearchTimeout); if (!scrollId.equals(response.getScrollId())) {
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Jun 21 04:02:44 UTC 2025 - 26.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/IndexingHelper.java
} } } } throw new SearchEngineClientException(response.buildFailureMessage()); } } if (logger.isInfoEnabled()) { if (docList.getContentSize() > 0) {
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 26.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/opensearch/user/allcommon/EsAbstractBehavior.java
final BulkResponse bulkResponse = bulkRequest.execute().actionGet(bulkTimeout); if (bulkResponse.hasFailures()) { throw new IllegalBehaviorStateException(bulkResponse.buildFailureMessage()); } response = client.prepareSearchScroll(scrollId).setScroll(scrollForDelete).execute().actionGet(scrollSearchTimeout); if (!scrollId.equals(response.getScrollId())) {
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Jun 21 04:02:44 UTC 2025 - 26.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/util/SuggestUtil.java
if (bulkResponse.hasFailures()) { throw new SuggesterException(bulkResponse.buildFailureMessage()); } response = client.prepareSearchScroll(scrollId) .setScroll(settings.getScrollTimeout()) .execute()
Registered: Fri Sep 19 09:08:11 UTC 2025 - Last Modified: Mon Sep 01 13:33:03 UTC 2025 - 17.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/SearchHelper.java
consumer.accept(builder); try { final BulkResponse response = builder.execute().get(); if (response.hasFailures()) { throw new SearchEngineClientException(response.buildFailureMessage()); } return true; } catch (final InterruptedException e) { throw new InterruptedRuntimeException(e); } catch (final ExecutionException e) {
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 35.8K bytes - Viewed (0) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/client/FesenClient.java
} return bulkRequest.execute(); }); if (bulkResponse.hasFailures()) { throw new OpenSearchAccessException(bulkResponse.buildFailureMessage()); } final String sid = scrollId; response = get(c -> c.prepareSearchScroll(sid).setScroll(scrollForDelete).execute());
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Aug 31 05:32:52 UTC 2025 - 25.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/opensearch/log/allcommon/EsAbstractBehavior.java
final BulkResponse bulkResponse = bulkRequest.execute().actionGet(bulkTimeout); if (bulkResponse.hasFailures()) { throw new IllegalBehaviorStateException(bulkResponse.buildFailureMessage()); } response = client.prepareSearchScroll(scrollId).setScroll(scrollForDelete).execute().actionGet(scrollSearchTimeout); if (!scrollId.equals(response.getScrollId())) {
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Jun 21 04:02:44 UTC 2025 - 26.4K bytes - Viewed (0)