[jira] [Commented] (FLUME-2721) Add support for custom serializer in Kafka Sink

[ https://issues.apache.org/jira/browse/FLUME-2721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14591376#comment-14591376 ] Benjamin Fiorini commented on FLUME-2721: - Problem is that what is sent to Kafka

[jira] [Created] (FLUME-2721) Add support for custom serializer in Kafka Sink

Benjamin Fiorini created FLUME-2721: --- Summary: Add support for custom serializer in Kafka Sink Key: FLUME-2721 URL: https://issues.apache.org/jira/browse/FLUME-2721 Project: Flume Issue

[jira] [Updated] (FLUME-2721) Add support for custom serializer in Kafka Sink

[ https://issues.apache.org/jira/browse/FLUME-2721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benjamin Fiorini updated FLUME-2721: Description: In 1.6.0, the Kafka sink just sends the content of the body. It would be

[jira] [Commented] (FLUME-2390) Flume-ElasticSearch Data gets posted multiple times when one of the event fail validation at elastic search sink for JSON Data

[ https://issues.apache.org/jira/browse/FLUME-2390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14504578#comment-14504578 ] Benjamin Fiorini commented on FLUME-2390: - Hi [~deepakas1] [~ejsarge] I believe

[jira] [Updated] (FLUME-2649) Elasticsearch sink doesn't handle JSON fields correctly

[ https://issues.apache.org/jira/browse/FLUME-2649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benjamin Fiorini updated FLUME-2649: Attachment: FLUME-2649-6.patch Voila, added your comment [~ejsarge] (y) Also updated the

[jira] [Commented] (FLUME-2649) Elasticsearch sink doesn't handle JSON fields correctly

[ https://issues.apache.org/jira/browse/FLUME-2649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14497655#comment-14497655 ] Benjamin Fiorini commented on FLUME-2649: - [~flisky] yes I don't like it either...

[jira] [Updated] (FLUME-2649) Elasticsearch sink doesn't handle JSON fields correctly

[ https://issues.apache.org/jira/browse/FLUME-2649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benjamin Fiorini updated FLUME-2649: Attachment: FLUME-2649-5.patch Thanks [~faelenor] for the clarification. I updated the

[jira] [Updated] (FLUME-2649) Elasticsearch sink doesn't handle JSON fields correctly

[ https://issues.apache.org/jira/browse/FLUME-2649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benjamin Fiorini updated FLUME-2649: Attachment: FLUME-2649-4.patch Addin a new patch [^FLUME-2649-4.patch] because comments

[jira] [Commented] (FLUME-2649) Elasticsearch sink doesn't handle JSON fields correctly

[ https://issues.apache.org/jira/browse/FLUME-2649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14495906#comment-14495906 ] Benjamin Fiorini commented on FLUME-2649: - I will post a new review board as soon

[jira] [Updated] (FLUME-2649) Elasticsearch sink doesn't handle JSON fields correctly

[ https://issues.apache.org/jira/browse/FLUME-2649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benjamin Fiorini updated FLUME-2649: Attachment: FLUME-2649-3.patch Hi [~flisky], I am not sure I managed to reproduce your

[jira] [Updated] (FLUME-2649) Elasticsearch sink doesn't handle JSON fields correctly

[ https://issues.apache.org/jira/browse/FLUME-2649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benjamin Fiorini updated FLUME-2649: Attachment: FLUME-2649-0.patch This is exactly what was suggested 2 years ago in

[jira] [Updated] (FLUME-2649) Elasticsearch sink doesn't handle JSON fields correctly

[ https://issues.apache.org/jira/browse/FLUME-2649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benjamin Fiorini updated FLUME-2649: Attachment: FLUME-2649-1.patch This patch passes all the tests. Elasticsearch sink

[jira] [Updated] (FLUME-2649) Elasticsearch sink doesn't handle JSON fields correctly

[ https://issues.apache.org/jira/browse/FLUME-2649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benjamin Fiorini updated FLUME-2649: Attachment: FLUME-2649-2.patch And this patch provides better tests. Elasticsearch sink

[jira] [Comment Edited] (FLUME-2498) Implement Taildir Source

[ https://issues.apache.org/jira/browse/FLUME-2498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14323992#comment-14323992 ] Benjamin Fiorini edited comment on FLUME-2498 at 2/17/15 9:35 AM:

[jira] [Commented] (FLUME-2498) Implement Taildir Source

[ https://issues.apache.org/jira/browse/FLUME-2498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14323992#comment-14323992 ] Benjamin Fiorini commented on FLUME-2498: - Great source, works very well from what

[jira] [Comment Edited] (FLUME-2390) Flume-ElasticSearch Data gets posted multiple times when one of the event fail validation at elastic search sink for JSON Data

[ https://issues.apache.org/jira/browse/FLUME-2390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14191759#comment-14191759 ] Benjamin Fiorini edited comment on FLUME-2390 at 10/31/14 12:49 PM:

[jira] [Commented] (FLUME-2390) Flume-ElasticSearch Data gets posted multiple times when one of the event fail validation at elastic search sink for JSON Data

[ https://issues.apache.org/jira/browse/FLUME-2390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14191759#comment-14191759 ] Benjamin Fiorini commented on FLUME-2390: - Duplicate of FLUME-2254, which has some

[jira] [Created] (FLUME-2512) Support RFC 5424 syslog format timestamp parsing microseconds

Benjamin Fiorini created FLUME-2512: --- Summary: Support RFC 5424 syslog format timestamp parsing microseconds Key: FLUME-2512 URL: https://issues.apache.org/jira/browse/FLUME-2512 Project: Flume

[jira] [Created] (FLUME-2355) Exception in process of Avro sink does not reset the cxnResetExecutor

Benjamin Fiorini created FLUME-2355: --- Summary: Exception in process of Avro sink does not reset the cxnResetExecutor Key: FLUME-2355 URL: https://issues.apache.org/jira/browse/FLUME-2355 Project: