I am currently migrating my elasticsearch client from Rest High Api Client to the new Elasticsearch 8+ Java Api Client. I want to convert the code: RangeQueryBuilder queryBuilder = QueryBuilders.rangeQuery(fieldName) .from(myFromRange.toString(), true) .to(myToRange.toString(), true); What is the substitute of include_lower and include_upper of Rest High Client in the new Java Api Client? I could not find it. Here is my current code: RangeQuery.Builder rangeQueryBuilder = new RangeQuery.Builder() .field(fieldNa ..read more

I have a small Elasticsearch cluster having 3 master nodes(2core,2gb t3.small ec2) and 2 data nodes data-0 and data-1 (2core 8GB m6a.large ec2 4gb max heap for data nodes). Cluster runs in an EKS cluster. Cluster has one index(40p1r) currently having around 920 million docs with index size of around 1.9TB. Cluster receives continuous live doc indexing traffic 24/7 at avg 60calls/sec and search query rate of 2calls/sec I upgraded the cluster from 8.3.1 to 8.13.4 on which I suddenly saw a huge number of document deletes which lead to huge number of segment merges. This lead to 100% cpu usage for ..read more

index/_analyze { "analyzer": "autocomplete", "field": "name", "text": "жаб" } gives me correct tokens: { "tokens": [{ "token": "žab", "start_offset": 0, "end_offset": 3, "type": "<ALPHANUM>", "position": 0 }] } now when i plugin in token žab into search it works, it is giving me results. Explain query: index/_validate/query?explain { "query": { "match": { "name": "жаб" } } } gives me { "_shards": { "total": 1, "successful": 1, "failed": 0 }, "valid": true, "explanatio ..read more

We are developing a search function for space rental products using Elasticsearch and MySQL. [Search form] From DateTime To DateTime Min Price Max Price The search form is the same as above, and there is no problem with Fulltext-search in ES. The problem is that when you search for a price, you need to calculate the amount to be paid within the search time in real time, search for a price range with the calculated price, and complete paging. ES searches Fulltext-search MySQL calculates prices in real time and filters the calculated prices according to Min Max Price I need to page the records ..read more

I have an index for each of our clients in ElasticSearch. Each client sends a large amount of information. Each client also has a different retention period for the information saved. Therefore, I am saving the information in daily indexes per client. This allows me to delete the indexes daily once the retention period has passed. The issue is that at midnight, when the new indexes are created, there is a substantial slowdown in ElasticSearch, causing all my servers to be under pressure. What should I do to fix this issue ..read more

I have 200 million documents in Elasticsearch. Each document is structured as follows: {"url": url, "username": username} Whenever I try to search for a specific domain like this: { "query": { "wildcard": { "url": { "value": "*test.com*" } } } } It successfully returns URLs like: {'url':'http://sd.test.com/login'} {'url':'http://test.com/register'} {'url':'http://admin.test.com:8080/'} However, it doesn't return all subdomains. For example, the following URL is not included in the search results: http://sds.test.com/User/Login It only returns it when I c ..read more

How can I sort the list of aliases using AliasesRequest? this is my old code Request request = new Request("GET", "/_cat/aliases/" + indexAliasName + "?format=json&s=is_write_index:desc,"); how to sort it by "is_write_index:desc" using new syntax in Java AliasesRequest.of(ar -> ar.name(pattern)); I need to add the parameter of the sorting to the request ..read more

I want to use https://www.elastic.co/guide/en/elasticsearch/reference/current/docs-bulk.html with raise_on_error=False. When some of the documents given to the bulk operation succeed and some do not how can I lik the errors to the data that I put in as the input? I intend to use this via python elasticsearch library ..read more

I have a field that contains non-deterministic JSON objects. I want this field to be indexed as a simple text so I can search its content later if needed. But I get error from elastic 'Can't get text on a START_OBJECT at 1:351'. Seems like it detects it is JSON and rejects it. Is there a way to make it work or my approach is not right ..read more

i have a running elasticserver on amazon linux having ip and port http://3.110.152.4:9200/ but in flask its not connecting, in code its working fine,but in flask its giving connection error. the code is : from flask import Flask, request, render_template, jsonify import time from elasticsearch import Elasticsearch, ConnectionError from sentence_transformers import SentenceTransformer app = Flask(__name__) # Initialize Sentence Transformer model model = SentenceTransformer("all-mpnet-base-v2") # Define the Elasticsearch connection function with retry logic # Define the search function def s ..read more