----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/13509/ -----------------------------------------------------------
Review request for Flume. Repository: flume-git Description ------- The ElasticsearchSink is quite aggressive in assuming that the incoming event is JSON. However, if it is not JSON or YAML then an exception is thrown which would block the queue from processing further messages. This patch catches Exception and writes the data as a simple field. Diffs ----- flume-ng-sinks/flume-ng-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/ContentBuilderUtil.java bf7c57c flume-ng-sinks/flume-ng-elasticsearch-sink/src/test/java/org/apache/flume/sink/elasticsearch/TestElasticSearchLogStashEventSerializer.java 9dff4b0 Diff: https://reviews.apache.org/r/13509/diff/ Testing ------- Mvn install passes. A custom build with this patch is currently running in many of our environments with no problems and the event which caused the issue was safely stored. Thanks, Edward Sargisson
