[jira] [Commented] (FLUME-3021) flume Elasticsearch 5.0 not support

[Helmut Wahrman (JIRA)]

    [ 
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)