[
https://issues.apache.org/jira/browse/FLUME-3021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15926762#comment-15926762
]
Helmut Wahrman commented on FLUME-3021:
---------------------------------------
Hi,
i applied the patch and rebuilt flume.
when i run it on elastic 5.2.2 i get a crash:
2017-03-15 06:17:37,814 (SinkRunner-PollingRunner-DefaultSinkProcessor) [ERROR
-
org.apache.flume.sink.elasticsearch.ElasticSearchSink.process(ElasticSearchSink.java:221)]
Failed to commit transaction. Transaction rolled back.
java.lang.IllegalStateException: Failed to close the XContentBuilder
at
org.elasticsearch.common.xcontent.XContentBuilder.close(XContentBuilder.java:997)
at
org.elasticsearch.common.xcontent.XContentBuilder.bytes(XContentBuilder.java:1007)
at
org.apache.flume.sink.elasticsearch.client.ElasticSearchTransportClient.addEvent(ElasticSearchTransportClient.java:169)
at
org.apache.flume.sink.elasticsearch.ElasticSearchSink.process(ElasticSearchSink.java:189)
at
org.apache.flume.sink.DefaultSinkProcessor.process(DefaultSinkProcessor.java:67)
at org.apache.flume.SinkRunner$PollingRunner.run(SinkRunner.java:145)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.io.IOException: Unclosed object or array found
at
org.elasticsearch.common.xcontent.json.JsonXContentGenerator.close(JsonXContentGenerator.java:415)
at
org.elasticsearch.common.xcontent.XContentBuilder.close(XContentBuilder.java:995)
... 6 more
2017-03-15 06:17:37,817 (SinkRunner-PollingRunner-DefaultSinkProcessor) [ERROR
- org.apache.flume.SinkRunner$PollingRunner.run(SinkRunner.java:158)] Unable to
deliver event. Exception follows.
java.lang.IllegalStateException: Failed to close the XContentBuilder
at
org.elasticsearch.common.xcontent.XContentBuilder.close(XContentBuilder.java:997)
at
org.elasticsearch.common.xcontent.XContentBuilder.bytes(XContentBuilder.java:1007)
at
org.apache.flume.sink.elasticsearch.client.ElasticSearchTransportClient.addEvent(ElasticSearchTransportClient.java:169)
at
org.apache.flume.sink.elasticsearch.ElasticSearchSink.process(ElasticSearchSink.java:189)
at
org.apache.flume.sink.DefaultSinkProcessor.process(DefaultSinkProcessor.java:67)
at org.apache.flume.SinkRunner$PollingRunner.run(SinkRunner.java:145)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.io.IOException: Unclosed object or array found
at
org.elasticsearch.common.xcontent.json.JsonXContentGenerator.close(JsonXContentGenerator.java:415)
at
org.elasticsearch.common.xcontent.XContentBuilder.close(XContentBuilder.java:995)
... 6 more
Any idea?
thanks,
Helmut
> flume Elasticsearch 5.0 not support
> -----------------------------------
>
> Key: FLUME-3021
> URL: https://issues.apache.org/jira/browse/FLUME-3021
> Project: Flume
> Issue Type: Bug
> Components: Sinks+Sources
> Affects Versions: v1.7.0
> Reporter: tycho_yang
> Assignee: Yonghao Zou
> Fix For: v1.8.0
>
> Attachments: FLUME-3021-0.patch
>
>
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)