Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 9 of 9 for hasFailures (0.06 seconds)

  1. src/main/java/org/codelibs/fess/timer/LogNotificationTarget.java

                    }
                    final BulkResponse response = bulkRequest.execute().actionGet(30_000L);
                    if (response.hasFailures()) {
                        logger.warn("Failed to write log notifications: {}", response.buildFailureMessage());
                    }
                }
            } catch (final Exception e) {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Mar 26 02:24:08 GMT 2026
    - 4.5K bytes
    - Click Count (0)
  2. src/main/java/org/codelibs/fess/score/ScoreBooster.java

         */
        protected void flush() {
            if (bulkRequestBuilder != null) {
                final BulkResponse response = bulkRequestBuilder.execute().actionGet(requestTimeout);
                if (response.hasFailures()) {
                    logger.warn("Failed to update scores: {}", response.buildFailureMessage());
                }
                bulkRequestBuilder = null;
            }
        }
    
        /**
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Aug 07 03:06:29 GMT 2025
    - 6.6K bytes
    - Click Count (0)
  3. src/main/java/org/codelibs/fess/app/web/api/admin/documents/ApiAdminDocumentsAction.java

                    itemMap.put("message", item.getFailureMessage());
                } else {
                    itemMap.put("id", item.getId());
                }
                return itemMap;
            }).toList()).status(response.hasFailures() ? Status.FAILED : Status.OK).result());
    
        }
    
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Jul 17 08:28:31 GMT 2025
    - 8.3K bytes
    - Click Count (0)
  4. 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) {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Dec 20 05:56:45 GMT 2025
    - 36.3K bytes
    - Click Count (0)
  5. src/main/java/org/codelibs/fess/opensearch/config/allcommon/EsAbstractBehavior.java

                    }
                    count += hits.length;
                    final BulkResponse bulkResponse = bulkRequest.execute().actionGet(bulkTimeout);
                    if (bulkResponse.hasFailures()) {
                        throw new IllegalBehaviorStateException(bulkResponse.buildFailureMessage());
                    }
    
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Nov 27 07:01:25 GMT 2025
    - 26.4K bytes
    - Click Count (0)
  6. src/main/java/org/codelibs/fess/helper/IndexingHelper.java

                                crawlingConfigHelper.getPipeline(configId).ifPresent(s -> builder.setPipeline(s));
                            });
                    if (response.hasFailures()) {
                        if (logger.isDebugEnabled()) {
                            final BulkItemResponse[] items = response.getItems();
                            if (docList.size() == items.length) {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 26.1K bytes
    - Click Count (0)
  7. src/main/java/org/codelibs/fess/opensearch/log/allcommon/EsAbstractBehavior.java

                    }
                    count += hits.length;
                    final BulkResponse bulkResponse = bulkRequest.execute().actionGet(bulkTimeout);
                    if (bulkResponse.hasFailures()) {
                        throw new IllegalBehaviorStateException(bulkResponse.buildFailureMessage());
                    }
    
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Nov 27 07:01:25 GMT 2025
    - 26.4K bytes
    - Click Count (0)
  8. src/main/java/org/codelibs/fess/opensearch/user/allcommon/EsAbstractBehavior.java

                    }
                    count += hits.length;
                    final BulkResponse bulkResponse = bulkRequest.execute().actionGet(bulkTimeout);
                    if (bulkResponse.hasFailures()) {
                        throw new IllegalBehaviorStateException(bulkResponse.buildFailureMessage());
                    }
    
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Nov 27 07:01:25 GMT 2025
    - 26.4K bytes
    - Click Count (0)
  9. src/main/java/org/codelibs/fess/opensearch/client/SearchEngineClient.java

                            return StringUtil.EMPTY;
                        });
                final BulkResponse response = builder.execute().actionGet(fessConfig.getIndexBulkTimeout());
                if (response.hasFailures()) {
                    if (createOnly) {
                        final long realFailures = Arrays.stream(response.getItems())
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Mar 26 14:36:23 GMT 2026
    - 138.6K bytes
    - Click Count (1)
Back to Top