Остановка поиска не удалось удалить реку на остановке
В последние дни я меняю владельца словаря asticsearch с "user2" на "user1" (находится в /home/user1, все время). После того, как убить старый процесс ES и запустить скрипт как user1, через несколько минут отключение скрипта без (на мой взгляд) логического сообщения. Кластер здоровья желтый, здесь _cat/health: 1513003812 15:50:12 asport yellow 1 1 31 31 0 0 31 0
Я использую JDBC реку, чтобы получить данные из базы данных MySQL.
Весь файл журнала доступен здесь: http://www.web-com.pl/files/asport.log
Последние строки из файла журнала:
org.elasticsearch.search.SearchParseException: [searcher1][0]: from[-1],size[-1]: Parse Failure [Failed to parse source [{"query":{"bool":{"boost":1,"must":[{"term":{"products_status":1}},{"term":{"products_temporarily_unavailable":0}}],"should":[{"match":{"products_name":{"query":"31309","operator":"and","boost":20}}},{"fuzzy_like_this":{"fields":["products_name_keyword"],"like_text":"31309","boost":5}},{"fuzzy_like_this":{"fields":["products_name_keyword"],"like_text":"31309","boost":2}},{"match":{"categories_name":{"query":"31309","boost":2}}},{"fuzzy_like_this":{"fields":["categories_name","products_model","products_description_seo_tag","category_tags","manufacturers_name","products_description","products_search_tags"],"like_text":"31309","boost":1}},{"match":{"products_name_ngram":{"query":"31309","boost":1}}},{"match_phrase_prefix":{"categories_name_keyword":{"query":"31309","boost":15}}},{"match_phrase_prefix":{"products_name_keyword":{"query":"31309","boost":15}}},{"match_phrase_prefix":{"products_name_keyword":{"query":"31309","boost":25}}},{"match":{"path_category_name_keyword":{"query":"31309","operator":"and","boost":50}}},"products_id^500"]}},"track_scores":true,"sort":{"_score":{"order":"desc"},"products_temporarily_unavailable":{"order":"desc"}},"size":8}]]
at org.elasticsearch.search.SearchService.parseSource(SearchService.java:747)
at org.elasticsearch.search.SearchService.createContext(SearchService.java:572)
at org.elasticsearch.search.SearchService.createAndPutContext(SearchService.java:544)
at org.elasticsearch.search.SearchService.executeQueryPhase(SearchService.java:306)
at org.elasticsearch.search.action.SearchServiceTransportAction$5.call(SearchServiceTransportAction.java:231)
at org.elasticsearch.search.action.SearchServiceTransportAction$5.call(SearchServiceTransportAction.java:228)
at org.elasticsearch.search.action.SearchServiceTransportAction$23.run(SearchServiceTransportAction.java:559)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Caused by: org.elasticsearch.index.query.QueryParsingException: [searcher1] [_na] query malformed, must start with start_object
at org.elasticsearch.index.query.QueryParseContext.parseInnerQuery(QueryParseContext.java:287)
at org.elasticsearch.index.query.BoolQueryParser.parse(BoolQueryParser.java:107)
at org.elasticsearch.index.query.QueryParseContext.parseInnerQuery(QueryParseContext.java:305)
at org.elasticsearch.index.query.IndexQueryParserService.innerParse(IndexQueryParserService.java:382)
at org.elasticsearch.index.query.IndexQueryParserService.parse(IndexQueryParserService.java:281)
at org.elasticsearch.index.query.IndexQueryParserService.parse(IndexQueryParserService.java:276)
at org.elasticsearch.search.query.QueryParseElement.parse(QueryParseElement.java:33)
at org.elasticsearch.search.SearchService.parseSource(SearchService.java:731)
... 9 more
[2017-12-11 15:31:37,564][INFO ][com.asquera.elasticsearch.plugins.http.HttpBasicServer] [Asport.pl] Authorization:Basic YXNwb3J0X2FkbWluOlV3NDAwNV9rcmE=, type: GET, Host:****:****@asport.pl:9486, Path:/searcher2/most_search/_search, :null, Request-IP:94.152.130.145, Client-IP:null, X-Client-IPnull
[2017-12-11 15:31:37,576][INFO ][com.asquera.elasticsearch.plugins.http.HttpBasicServer] [Asport.pl] Authorization:Basic YXNwb3J0X2FkbWluOlV3NDAwNV9rcmE=, type: GET, Host:****:****@asport.pl:9486, Path:/searcher1/ajax_products/_search, :null, Request-IP:94.152.130.145, Client-IP:null, X-Client-IPnull
[2017-12-11 15:31:38,128][INFO ][com.asquera.elasticsearch.plugins.http.HttpBasicServer] [Asport.pl] Authorization:Basic YXNwb3J0X2FkbWluOlV3NDAwNV9rcmE=, type: GET, Host:****:****@asport.pl:9486, Path:/searcher3/producers/_search, :null, Request-IP:94.152.130.145, Client-IP:null, X-Client-IPnull
[2017-12-11 15:31:38,133][INFO ][com.asquera.elasticsearch.plugins.http.HttpBasicServer] [Asport.pl] Authorization:Basic YXNwb3J0X2FkbWluOlV3NDAwNV9rcmE=, type: GET, Host:****:****@asport.pl:9486, Path:/searcher4/categories/_search, :null, Request-IP:94.152.130.145, Client-IP:null, X-Client-IPnull
[2017-12-11 15:32:53,092][INFO ][com.asquera.elasticsearch.plugins.http.HttpBasicServer] [Asport.pl] Authorization:Basic YXNwb3J0X2FkbWluOlV3NDAwNV9rcmE=, type: GET, Host:****:****@asport.pl:9486, Path:/searcher2/most_search/_search, :null, Request-IP:94.152.130.145, Client-IP:null, X-Client-IPnull
[2017-12-11 15:32:53,100][INFO ][com.asquera.elasticsearch.plugins.http.HttpBasicServer] [Asport.pl] Authorization:Basic YXNwb3J0X2FkbWluOlV3NDAwNV9rcmE=, type: GET, Host:****:****@asport.pl:9486, Path:/searcher1/ajax_products/_search, :null, Request-IP:94.152.130.145, Client-IP:null, X-Client-IPnull
[2017-12-11 15:32:53,219][INFO ][com.asquera.elasticsearch.plugins.http.HttpBasicServer] [Asport.pl] Authorization:Basic YXNwb3J0X2FkbWluOlV3NDAwNV9rcmE=, type: GET, Host:****:****@asport.pl:9486, Path:/searcher3/producers/_search, :null, Request-IP:94.152.130.145, Client-IP:null, X-Client-IPnull
[2017-12-11 15:32:53,222][INFO ][com.asquera.elasticsearch.plugins.http.HttpBasicServer] [Asport.pl] Authorization:Basic YXNwb3J0X2FkbWluOlV3NDAwNV9rcmE=, type: GET, Host:****:****@asport.pl:9486, Path:/searcher4/categories/_search, :null, Request-IP:94.152.130.145, Client-IP:null, X-Client-IPnull
[2017-12-11 15:33:38,885][INFO ][com.asquera.elasticsearch.plugins.http.HttpBasicServer] [Asport.pl] Authorization:Basic YXNwb3J0X2FkbWluOlV3NDAwNV9rcmE=, type: GET, Host:****:****@asport.pl:9486, Path:/searcher2/most_search/_search, :null, Request-IP:94.152.130.145, Client-IP:null, X-Client-IPnull
[2017-12-11 15:33:38,894][INFO ][com.asquera.elasticsearch.plugins.http.HttpBasicServer] [Asport.pl] Authorization:Basic YXNwb3J0X2FkbWluOlV3NDAwNV9rcmE=, type: GET, Host:****:****@asport.pl:9486, Path:/searcher1/ajax_products/_search, :null, Request-IP:94.152.130.145, Client-IP:null, X-Client-IPnull
[2017-12-11 15:33:38,971][INFO ][com.asquera.elasticsearch.plugins.http.HttpBasicServer] [Asport.pl] Authorization:Basic YXNwb3J0X2FkbWluOlV3NDAwNV9rcmE=, type: GET, Host:****:****@asport.pl:9486, Path:/searcher3/producers/_search, :null, Request-IP:94.152.130.145, Client-IP:null, X-Client-IPnull
[2017-12-11 15:33:38,975][INFO ][com.asquera.elasticsearch.plugins.http.HttpBasicServer] [Asport.pl] Authorization:Basic YXNwb3J0X2FkbWluOlV3NDAwNV9rcmE=, type: GET, Host:****:****@asport.pl:9486, Path:/searcher4/categories/_search, :null, Request-IP:94.152.130.145, Client-IP:null, X-Client-IPnull
[2017-12-11 15:34:26,720][INFO ][node ] [Asport.pl] stopping ...
[2017-12-11 15:34:26,723][INFO ][river.jdbc.JDBCRiver ] river closed [jdbc/auctions]
[2017-12-11 15:34:26,726][WARN ][river ] [Asport.pl] failed to delete river on stop [jdbc]/[auctions]
org.elasticsearch.ElasticsearchException: unable to delete, river state missing: auctions
at org.xbib.elasticsearch.plugin.jdbc.state.RiverStateService$3.execute(RiverStateService.java:314)
at org.elasticsearch.cluster.service.InternalClusterService$UpdateTask.run(InternalClusterService.java:374)
at org.elasticsearch.common.util.concurrent.PrioritizedEsThreadPoolExecutor$TieBreakingPrioritizedRunnable.runAndClean(PrioritizedEsThreadPoolExecutor.java:196)
at org.elasticsearch.common.util.concurrent.PrioritizedEsThreadPoolExecutor$TieBreakingPrioritizedRunnable.run(PrioritizedEsThreadPoolExecutor.java:162)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
[2017-12-11 15:34:26,734][INFO ][river.jdbc.JDBCRiver ] river closed [jdbc/categories]
[2017-12-11 15:34:26,734][WARN ][river ] [Asport.pl] failed to delete river on stop [jdbc]/[categories]
org.elasticsearch.ElasticsearchException: unable to delete, river state missing: categories
at org.xbib.elasticsearch.plugin.jdbc.state.RiverStateService$3.execute(RiverStateService.java:314)
at org.elasticsearch.cluster.service.InternalClusterService$UpdateTask.run(InternalClusterService.java:374)
at org.elasticsearch.common.util.concurrent.PrioritizedEsThreadPoolExecutor$TieBreakingPrioritizedRunnable.runAndClean(PrioritizedEsThreadPoolExecutor.java:196)
at org.elasticsearch.common.util.concurrent.PrioritizedEsThreadPoolExecutor$TieBreakingPrioritizedRunnable.run(PrioritizedEsThreadPoolExecutor.java:162)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
[2017-12-11 15:34:26,734][INFO ][river.jdbc.JDBCRiver ] river closed [jdbc/count_unfiltered]
[2017-12-11 15:34:26,735][WARN ][river ] [Asport.pl] failed to delete river on stop [jdbc]/[count_unfiltered]
org.elasticsearch.ElasticsearchException: unable to delete, river state missing: count_unfiltered
at org.xbib.elasticsearch.plugin.jdbc.state.RiverStateService$3.execute(RiverStateService.java:314)
at org.elasticsearch.cluster.service.InternalClusterService$UpdateTask.run(InternalClusterService.java:374)
at org.elasticsearch.common.util.concurrent.PrioritizedEsThreadPoolExecutor$TieBreakingPrioritizedRunnable.runAndClean(PrioritizedEsThreadPoolExecutor.java:196)
at org.elasticsearch.common.util.concurrent.PrioritizedEsThreadPoolExecutor$TieBreakingPrioritizedRunnable.run(PrioritizedEsThreadPoolExecutor.java:162)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
[2017-12-11 15:34:26,735][INFO ][river.jdbc.JDBCRiver ] river closed [jdbc/most_search]
[2017-12-11 15:34:26,737][WARN ][river ] [Asport.pl] failed to delete river on stop [jdbc]/[most_search]
org.elasticsearch.ElasticsearchException: unable to delete, river state missing: most_search
at org.xbib.elasticsearch.plugin.jdbc.state.RiverStateService$3.execute(RiverStateService.java:314)
at org.elasticsearch.cluster.service.InternalClusterService$UpdateTask.run(InternalClusterService.java:374)
at org.elasticsearch.common.util.concurrent.PrioritizedEsThreadPoolExecutor$TieBreakingPrioritizedRunnable.runAndClean(PrioritizedEsThreadPoolExecutor.java:196)
at org.elasticsearch.common.util.concurrent.PrioritizedEsThreadPoolExecutor$TieBreakingPrioritizedRunnable.run(PrioritizedEsThreadPoolExecutor.java:162)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
[2017-12-11 15:34:26,737][INFO ][river.jdbc.JDBCRiver ] river closed [jdbc/ajax_products]
[2017-12-11 15:34:26,738][WARN ][river ] [Asport.pl] failed to delete river on stop [jdbc]/[ajax_products]
org.elasticsearch.ElasticsearchException: unable to delete, river state missing: ajax_products
at org.xbib.elasticsearch.plugin.jdbc.state.RiverStateService$3.execute(RiverStateService.java:314)
at org.elasticsearch.cluster.service.InternalClusterService$UpdateTask.run(InternalClusterService.java:374)
at org.elasticsearch.common.util.concurrent.PrioritizedEsThreadPoolExecutor$TieBreakingPrioritizedRunnable.runAndClean(PrioritizedEsThreadPoolExecutor.java:196)
at org.elasticsearch.common.util.concurrent.PrioritizedEsThreadPoolExecutor$TieBreakingPrioritizedRunnable.run(PrioritizedEsThreadPoolExecutor.java:162)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
[2017-12-11 15:34:26,738][INFO ][river.jdbc.JDBCRiver ] river closed [jdbc/producers]
[2017-12-11 15:34:26,739][WARN ][river ] [Asport.pl] failed to delete river on stop [jdbc]/[producers]
org.elasticsearch.ElasticsearchException: unable to delete, river state missing: producers
at org.xbib.elasticsearch.plugin.jdbc.state.RiverStateService$3.execute(RiverStateService.java:314)
at org.elasticsearch.cluster.service.InternalClusterService$UpdateTask.run(InternalClusterService.java:374)
at org.elasticsearch.common.util.concurrent.PrioritizedEsThreadPoolExecutor$TieBreakingPrioritizedRunnable.runAndClean(PrioritizedEsThreadPoolExecutor.java:196)
at org.elasticsearch.common.util.concurrent.PrioritizedEsThreadPoolExecutor$TieBreakingPrioritizedRunnable.run(PrioritizedEsThreadPoolExecutor.java:162)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
[2017-12-11 15:34:26,851][INFO ][node ] [Asport.pl] stopped
[2017-12-11 15:34:26,852][INFO ][node ] [Asport.pl] closing ...
[2017-12-11 15:34:26,869][INFO ][node ] [Asport.pl] closed