[
https://issues.apache.org/jira/browse/FLINK-14576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao updated FLINK-14576:
-----------------------------
Affects Version/s: 1.10.0
> Elasticsearch (v6.3.1) sink end-to-end test instable
> ----------------------------------------------------
>
> Key: FLINK-14576
> URL: https://issues.apache.org/jira/browse/FLINK-14576
> Project: Flink
> Issue Type: Bug
> Components: Connectors / ElasticSearch, Tests
> Affects Versions: 1.10.0
> Reporter: Gary Yao
> Priority: Critical
> Labels: test-stability
>
> https://api.travis-ci.org/v3/job/604417300/log.txt
> {noformat}
> 2019-10-29 17:12:13,668 ERROR
> org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase -
> Failed Elasticsearch item request: [:intentional invalid index:]
> ElasticsearchException[Elasticsearch exception
> [type=invalid_index_name_exception, reason=Invalid index name [:intentional
> invalid index:], must not contain the following characters [ , ", *, \, <, |,
> ,, >, /, ?]]]
> [:intentional invalid index:] ElasticsearchException[Elasticsearch exception
> [type=invalid_index_name_exception, reason=Invalid index name [:intentional
> invalid index:], must not contain the following characters [ , ", *, \, <, |,
> ,, >, /, ?]]]
> at
> org.elasticsearch.ElasticsearchException.innerFromXContent(ElasticsearchException.java:510)
> at
> org.elasticsearch.ElasticsearchException.fromXContent(ElasticsearchException.java:421)
> at
> org.elasticsearch.action.bulk.BulkItemResponse.fromXContent(BulkItemResponse.java:135)
> at
> org.elasticsearch.action.bulk.BulkResponse.fromXContent(BulkResponse.java:198)
> at
> org.elasticsearch.client.RestHighLevelClient.parseEntity(RestHighLevelClient.java:653)
> at
> org.elasticsearch.client.RestHighLevelClient.lambda$performRequestAsyncAndParseEntity$3(RestHighLevelClient.java:549)
> at
> org.elasticsearch.client.RestHighLevelClient$1.onSuccess(RestHighLevelClient.java:580)
> at
> org.elasticsearch.client.RestClient$FailureTrackingResponseListener.onSuccess(RestClient.java:621)
> at org.elasticsearch.client.RestClient$1.completed(RestClient.java:375)
> at org.elasticsearch.client.RestClient$1.completed(RestClient.java:366)
> at
> org.apache.http.concurrent.BasicFuture.completed(BasicFuture.java:119)
> at
> org.apache.http.impl.nio.client.DefaultClientExchangeHandlerImpl.responseCompleted(DefaultClientExchangeHandlerImpl.java:177)
> at
> org.apache.http.nio.protocol.HttpAsyncRequestExecutor.processResponse(HttpAsyncRequestExecutor.java:436)
> at
> org.apache.http.nio.protocol.HttpAsyncRequestExecutor.inputReady(HttpAsyncRequestExecutor.java:326)
> at
> org.apache.http.impl.nio.DefaultNHttpClientConnection.consumeInput(DefaultNHttpClientConnection.java:265)
> at
> org.apache.http.impl.nio.client.InternalIODispatch.onInputReady(InternalIODispatch.java:81)
> at
> org.apache.http.impl.nio.client.InternalIODispatch.onInputReady(InternalIODispatch.java:39)
> at
> org.apache.http.impl.nio.reactor.AbstractIODispatch.inputReady(AbstractIODispatch.java:114)
> at
> org.apache.http.impl.nio.reactor.BaseIOReactor.readable(BaseIOReactor.java:162)
> at
> org.apache.http.impl.nio.reactor.AbstractIOReactor.processEvent(AbstractIOReactor.java:337)
> at
> org.apache.http.impl.nio.reactor.AbstractIOReactor.processEvents(AbstractIOReactor.java:315)
> at
> org.apache.http.impl.nio.reactor.AbstractIOReactor.execute(AbstractIOReactor.java:276)
> at
> org.apache.http.impl.nio.reactor.BaseIOReactor.execute(BaseIOReactor.java:104)
> at
> org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor$Worker.run(AbstractMultiworkerIOReactor.java:588)
> at java.lang.Thread.run(Thread.java:748)
> 2019-10-29 17:12:13,753 ERROR
> org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase -
> Failed Elasticsearch item request: [:intentional invalid index:]
> ElasticsearchException[Elasticsearch exception
> [type=invalid_index_name_exception, reason=Invalid index name [:intentional
> invalid index:], must not contain the following characters [ , ", *, \, <, |,
> ,, >, /, ?]]]
> [:intentional invalid index:] ElasticsearchException[Elasticsearch exception
> [type=invalid_index_name_exception, reason=Invalid index name [:intentional
> invalid index:], must not contain the following characters [ , ", *, \, <, |,
> ,, >, /, ?]]]
> at
> org.elasticsearch.ElasticsearchException.innerFromXContent(ElasticsearchException.java:510)
> at
> org.elasticsearch.ElasticsearchException.fromXContent(ElasticsearchException.java:421)
> at
> org.elasticsearch.action.bulk.BulkItemResponse.fromXContent(BulkItemResponse.java:135)
> at
> org.elasticsearch.action.bulk.BulkResponse.fromXContent(BulkResponse.java:198)
> at
> org.elasticsearch.client.RestHighLevelClient.parseEntity(RestHighLevelClient.java:653)
> at
> org.elasticsearch.client.RestHighLevelClient.lambda$performRequestAsyncAndParseEntity$3(RestHighLevelClient.java:549)
> at
> org.elasticsearch.client.RestHighLevelClient$1.onSuccess(RestHighLevelClient.java:580)
> at
> org.elasticsearch.client.RestClient$FailureTrackingResponseListener.onSuccess(RestClient.java:621)
> at org.elasticsearch.client.RestClient$1.completed(RestClient.java:375)
> at org.elasticsearch.client.RestClient$1.completed(RestClient.java:366)
> at
> org.apache.http.concurrent.BasicFuture.completed(BasicFuture.java:119)
> at
> org.apache.http.impl.nio.client.DefaultClientExchangeHandlerImpl.responseCompleted(DefaultClientExchangeHandlerImpl.java:177)
> at
> org.apache.http.nio.protocol.HttpAsyncRequestExecutor.processResponse(HttpAsyncRequestExecutor.java:436)
> at
> org.apache.http.nio.protocol.HttpAsyncRequestExecutor.inputReady(HttpAsyncRequestExecutor.java:326)
> at
> org.apache.http.impl.nio.DefaultNHttpClientConnection.consumeInput(DefaultNHttpClientConnection.java:265)
> at
> org.apache.http.impl.nio.client.InternalIODispatch.onInputReady(InternalIODispatch.java:81)
> at
> org.apache.http.impl.nio.client.InternalIODispatch.onInputReady(InternalIODispatch.java:39)
> at
> org.apache.http.impl.nio.reactor.AbstractIODispatch.inputReady(AbstractIODispatch.java:114)
> at
> org.apache.http.impl.nio.reactor.BaseIOReactor.readable(BaseIOReactor.java:162)
> at
> org.apache.http.impl.nio.reactor.AbstractIOReactor.processEvent(AbstractIOReactor.java:337)
> at
> org.apache.http.impl.nio.reactor.AbstractIOReactor.processEvents(AbstractIOReactor.java:315)
> at
> org.apache.http.impl.nio.reactor.AbstractIOReactor.execute(AbstractIOReactor.java:276)
> at
> org.apache.http.impl.nio.reactor.BaseIOReactor.execute(BaseIOReactor.java:104)
> at
> org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor$Worker.run(AbstractMultiworkerIOReactor.java:588)
> at java.lang.Thread.run(Thread.java:748)
> 2019-10-29 17:12:14,000 INFO org.apache.flink.runtime.taskmanager.Task
> - Source: Sequence Source -> Flat Map -> Sink: Unnamed (1/1)
> (cc8868ddb547d2fa8d6b40d55ace73db) switched from RUNNING to FINISHED.
> 2019-10-29 17:12:14,000 INFO org.apache.flink.runtime.taskmanager.Task
> - Freeing task resources for Source: Sequence Source -> Flat
> Map -> Sink: Unnamed (1/1) (cc8868ddb547d2fa8d6b40d55ace73db).
> 2019-10-29 17:12:14,001 INFO org.apache.flink.runtime.taskmanager.Task
> - Ensuring all FileSystem streams are closed for task Source:
> Sequence Source -> Flat Map -> Sink: Unnamed (1/1)
> (cc8868ddb547d2fa8d6b40d55ace73db) [FINISHED]
> 2019-10-29 17:12:14,002 INFO
> org.apache.flink.runtime.taskexecutor.TaskExecutor -
> Un-registering task and sending final execution state FINISHED to JobManager
> for task Source: Sequence Source -> Flat Map -> Sink: Unnamed
> cc8868ddb547d2fa8d6b40d55ace73db.
> 2019-10-29 17:12:14,206 INFO
> org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot
> TaskSlot(index:0, state:ACTIVE, resource profile:
> ResourceProfile{cpuCores=1.7976931348623157E308, heapMemoryInMB=2147483647,
> directMemoryInMB=2147483647, nativeMemoryInMB=2147483647,
> networkMemoryInMB=2147483647, managedMemoryInMB=639}, allocationId:
> 082904694550c7a1f513f6122150918b, jobId: 56058cfc7a89ac819704bbdfc3c8cb1b).
> 2019-10-29 17:12:14,215 INFO
> org.apache.flink.runtime.taskexecutor.JobLeaderService - Remove job
> 56058cfc7a89ac819704bbdfc3c8cb1b from job leader monitoring.
> 2019-10-29 17:12:14,215 INFO
> org.apache.flink.runtime.taskexecutor.TaskExecutor - Close
> JobManager connection for job 56058cfc7a89ac819704bbdfc3c8cb1b.
> 2019-10-29 17:12:14,242 INFO
> org.apache.flink.runtime.taskexecutor.TaskExecutor - Close
> JobManager connection for job 56058cfc7a89ac819704bbdfc3c8cb1b.
> 2019-10-29 17:12:14,246 INFO
> org.apache.flink.runtime.taskexecutor.JobLeaderService - Cannot
> reconnect to job 56058cfc7a89ac819704bbdfc3c8cb1b because it is not
> registered.
> Checking for non-empty .out files...
> No non-empty .out files.
> [FAIL] 'Elasticsearch (v6.3.1) sink end-to-end test' failed after 0 minutes
> and 49 seconds! Test exited with exit code 0 but the logs contained errors,
> exceptions or non-empty .out files
> {noformat}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
