I have a Kafka topic and a Spark application. The Spark application gets data from Kafka topic, pre aggregates it and stores it in Elastic Search. Sounds simple, right? Everything works fine as expected, but the minute I set “spark.cores” property something other than 1, I start getting After researching a bit, I think the error is because multiple cores
Tag: elasticsearch
Why this error coming failed to load elasticsearch nodes in spring boot?
I am trying to use elasticsearch in my webapplication. I am using spring boot 2.0.6. I didn’t add any configuration file elastic search is auto configured by spring boot. I added spring data elastic search properties in application.properties like this spring-data-elasticsearch-3.0.11 elasticsearch-5.6.12 When i run my application console showing I added one simple example for demo purpose but i am
How to add Bucket Sort to Query Aggregation
I have a ElasticSearch Query that is working well (curl), is my first Query, First I am filtering by Organization (Multitenancy), then group by Customer, Finally sum the amount of the sales but I only want to have the 3 best customers. My question is.. How to build the aggregation with the AggregationBuilders to get “bucket_sort” statement. I got the
NoNodeAvailableException : None of the configured nodes are available
I’m trying to search from Elastic Search within my Java Web Service, here’s how I use now : The 1st line could work without an error, but when it goes to the 2nd line, the exception down below will occur : NoNodeAvailableException[None of the configured nodes are available: [{#transport#-1}{TskPSVeBRR6CvCzP9EVhkQ}{192.168.10.150}{192.168.10.150:9200}]] No matter I use 9200 or 9300 to set the port,
IndexNotFoundException[no such index]
I was running my first elasticsearch test case, I am using Java as the solution perspective to do elasticsearch experiment. it works perfectly fine in eclipse Debug Mode, the debug mode result: But when I try this on in normal Run application mode, I am getting the following exception and I have no idea at all. Please guide me. The
How to enable query logging in Spring-data-elasticsearch
I use spring-data-elasticsearch framework to get query result from elasticsearch server, the java code like this: While how can I know the raw http query sent to elasticssearch server? How can I enable the logging, I tried add log4j, but it seems the spring-data-elasticsearch doesn’t log the query. Answer After digging through the spring data code i found this helpful
Liquibase or Flyway database migration alternative for Elasticsearch
I am pretty new to ES. I have been trying to search for a db migration tool for long and I could not find one. I am wondering if anyone could help to point me to the right direction. I would be using Elasticsearch as a primary datastore in my project. I would like to version all mapping and configuration