----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/10379/#review19419 -----------------------------------------------------------
Hmm, I'm not really OK with breaking API compatibility unless it's just impossible not to do it. I think we should expose a new interface that serializers can implement and do RTTI at configure() time in the sink in order to determine whether the user has specified (via the Flume config file) a plugin that has implemented the old interface or the new interface for their serializer. Then we can put everything we want into the new interface without breaking people who have deployed Flume 1.3.1 in production. Does that sound doable? - Mike Percy On April 18, 2013, 11:39 p.m., Edward Sargisson wrote: > > ----------------------------------------------------------- > This is an automatically generated e-mail. To reply, visit: > https://reviews.apache.org/r/10379/ > ----------------------------------------------------------- > > (Updated April 18, 2013, 11:39 p.m.) > > > Review request for Flume and Hari Shreedharan. > > > Description > ------- > > This change gets the timestamp from the event and uses it (in UTC) to > determine the name of the index to write to. This is required to match the > behaviour of Logstash so that Kibana can find the log events. > The previous code would use the current time and would do it in the timezone > of the Flume agent's host. > > > This addresses bug FLUME-1782. > https://issues.apache.org/jira/browse/FLUME-1782 > > > Diffs > ----- > > flume-ng-doc/sphinx/FlumeUserGuide.rst 38f2205 > > flume-ng-sinks/flume-ng-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/ElasticSearchDynamicSerializer.java > aa7ad39 > > flume-ng-sinks/flume-ng-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/ElasticSearchEventSerializer.java > dc6a093 > > flume-ng-sinks/flume-ng-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/ElasticSearchLogStashEventSerializer.java > 3638368 > > flume-ng-sinks/flume-ng-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/ElasticSearchSink.java > 1b3db14 > > flume-ng-sinks/flume-ng-elasticsearch-sink/src/test/java/org/apache/flume/sink/elasticsearch/TestElasticSearchDynamicSerializer.java > 43a4b12 > > flume-ng-sinks/flume-ng-elasticsearch-sink/src/test/java/org/apache/flume/sink/elasticsearch/TestElasticSearchLogStashEventSerializer.java > 9dff4b0 > > flume-ng-sinks/flume-ng-elasticsearch-sink/src/test/java/org/apache/flume/sink/elasticsearch/TestElasticSearchSink.java > 94b95b1 > > Diff: https://reviews.apache.org/r/10379/diff/ > > > Testing > ------- > > All unit tests and integration tests pass. A snapshot using commit > 5b9d31f1ad228 and the patch for flume-1972 has passed our internal > integration tests using customisations. > > > Thanks, > > Edward Sargisson > >
