The analyzer does not work,So who can help me.Thanks!Here is my error and example:
(1)error:
{
"error": {
"root_cause": [
{
"type": "x_content_parse_exception",
"reason": "[3:12] [analyze_request] failed to parse field [text]"
}
],
"type": "x_content_parse_exception",
"reason": "[3:12] [analyze_request] failed to parse field [text]",
"caused_by": {
"type": "json_parse_exception",
"reason": "Illegal unquoted character ((CTRL-CHAR, code 10)): has to be escaped using backslash to be included in string value\n at [Source: org.elasticsearch.transport.netty4.ByteBufStreamInput@6eb3d4e; line: 3, column: 206]"
}
},
"status": 400
}
(2)example:
POST _analyze
{
"analyzer": "ik_max_word",
"text": ["[2019-11-29 02:14:26,704][ERROR][865463d59436486a8355f449c3b740bf][pool-1-kafka-thread-4][c.c.c.i.m.c.thread.KafkaConsumerRunner ][line:101]:es集群超时异常,topic=clm_event_err_log_topic
java.net.SocketTimeoutException: 30,000 milliseconds timeout on connection http-outgoing-390 [ACTIVE]
at org.elasticsearch.client.RestClient.extractAndWrapCause(RestClient.java:773)
at org.elasticsearch.client.RestClient.performRequest(RestClient.java:218)
at org.elasticsearch.client.RestClient.performRequest(RestClient.java:221)
at org.elasticsearch.client.RestClient.performRequest(RestClient.java:205)
at org.elasticsearch.client.RestHighLevelClient.internalPerformRequest(RestHighLevelClient.java:1454)
at org.elasticsearch.client.RestHighLevelClient.performRequest(RestHighLevelClient.java:1424)
at org.elasticsearch.client.RestHighLevelClient.performRequestAndParseEntity(RestHighLevelClient.java:1394)
at org.elasticsearch.client.RestHighLevelClient.bulk(RestHighLevelClient.java:492)
at com.cupdata.clmes.api.es.dao.impl.EsDaoImpl.saveOrUpdateOrDelete(EsDaoImpl.java:334)
at com.cupdata.clmes.indexer.model.handle.DefaultConsumerHandle.handle(DefaultConsumerHandle.java:55)
at com.cupdata.clmes.indexer.model.consumer.thread.KafkaConsumerRunner.handleRecords(KafkaConsumerRunner.java:95)
at com.cupdata.clmes.indexer.model.consumer.thread.KafkaConsumerRunner.run(KafkaConsumerRunner.java:68)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)
Suppressed: java.net.SocketTimeoutException: 30,000 milliseconds timeout on connection http-outgoing-388 [ACTIVE]
at org.elasticsearch.client.RestClient.extractAndWrapCause(RestClient.java:773)
at org.elasticsearch.client.RestClient.performRequest(RestClient.java:218)
... 12 common frames omitted
Caused by: java.net.SocketTimeoutException: 30,000 milliseconds timeout on connection http-outgoing-388 [ACTIVE]
at org.apache.http.nio.protocol.HttpAsyncRequestExecutor.timeout(HttpAsyncRequestExecutor.java:387)
at org.apache.http.impl.nio.client.InternalIODispatch.onTimeout(InternalIODispatch.java:92)
at org.apache.http.impl.nio.client.InternalIODispatch.onTimeout(InternalIODispatch.java:39)
at org.apache.http.impl.nio.reactor.AbstractIODispatch.timeout(AbstractIODispatch.java:175)
at org.apache.http.impl.nio.reactor.BaseIOReactor.sessionTimedOut(BaseIOReactor.java:263)
at org.apache.http.impl.nio.reactor.AbstractIOReactor.timeoutCheck(AbstractIOReactor.java:492)
at org.apache.http.impl.nio.reactor.BaseIOReactor.validate(BaseIOReactor.java:213)
at org.apache.http.impl.nio.reactor.AbstractIOReactor.execute(AbstractIOReactor.java:280)
at org.apache.http.impl.nio.reactor.BaseIOReactor.execute(BaseIOReactor.java:104)
at org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor$Worker.run(AbstractMultiworkerIOReactor.java:591)
... 1 common frames omitted
Caused by: java.net.SocketTimeoutException: 30,000 milliseconds timeout on connection http-outgoing-390 [ACTIVE]
at org.apache.http.nio.protocol.HttpAsyncRequestExecutor.timeout(HttpAsyncRequestExecutor.java:387)
at org.apache.http.impl.nio.client.InternalIODispatch.onTimeout(InternalIODispatch.java:92)
at org.apache.http.impl.nio.client.InternalIODispatch.onTimeout(InternalIODispatch.java:39)
at org.apache.http.impl.nio.reactor.AbstractIODispatch.timeout(AbstractIODispatch.java:175)
at org.apache.http.impl.nio.reactor.BaseIOReactor.sessionTimedOut(BaseIOReactor.java:263)
at org.apache.http.impl.nio.reactor.AbstractIOReactor.timeoutCheck(AbstractIOReactor.java:492)
at org.apache.http.impl.nio.reactor.BaseIOReactor.validate(BaseIOReactor.java:213)
at org.apache.http.impl.nio.reactor.AbstractIOReactor.execute(AbstractIOReactor.java:280)
at org.apache.http.impl.nio.reactor.BaseIOReactor.execute(BaseIOReactor.java:104)
at org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor$Worker.run(AbstractMultiworkerIOReactor.java:591)
... 1 common frames omitted"]
}
This is an SocketTimeoutException log when I request to Elasticsearch by the resthighlevelapi.And I put the log to Elasticsearch.I use filebeat to collect the log,and push it to kafka.Than I have a consumer to put the log to es.
Can you please create a minimal recreation script with data and mappings that can be run from the Kibana dev console or curl? How is the analyzer configured? Are there any error messages in the Elasticsearch logs?
Apache, Apache Lucene, Apache Hadoop, Hadoop, HDFS and the yellow elephant
logo are trademarks of the
Apache Software Foundation
in the United States and/or other countries.