You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flume.apache.org by Satoshi Iijima <pa...@yahoo.co.jp> on 2014/05/23 21:44:51 UTC

Review Request 21876: FLUME-2207 HDFS file suffix style index suffix in ElasticSearchSink

-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/21876/
-----------------------------------------------------------

Review request for Flume.


Repository: flume-git


Description
-------

This feature has already been implemented by TimeBasedIndexNameBuilder which is the default indexNameBuilder. 
But it does not work because of a small bug.

Example is below:

a1.sinks.k1.type = elasticsearch
a1.sinks.k1.indexNameBuilder.dateFormat = yyyy-MM-dd-HH
a1.sinks.k1.indexNameBuilder.timeZone = Asia/Tokyo
a1.sinks.k1.indexName = foo_index
a1.sinks.k1.indexType = bar_type
a1.sinks.k1.hostNames = 127.0.0.1:9200
a1.sinks.k1.channel = c1


Diffs
-----


Diff: https://reviews.apache.org/r/21876/diff/


Testing
-------


Thanks,

Satoshi Iijima


Re: Review Request 21876: FLUME-2207 HDFS file suffix style index suffix in ElasticSearchSink

Posted by Satoshi Iijima <pa...@yahoo.co.jp>.
-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/21876/
-----------------------------------------------------------

(Updated May 24, 2014, 4:51 a.m.)


Review request for Flume.


Repository: flume-git


Description
-------

This feature has already been implemented by TimeBasedIndexNameBuilder which is the default indexNameBuilder. 
But it does not work because of a small bug.

Example is below:

a1.sinks.k1.type = elasticsearch
a1.sinks.k1.indexNameBuilder.dateFormat = yyyy-MM-dd-HH
a1.sinks.k1.indexNameBuilder.timeZone = Asia/Tokyo
a1.sinks.k1.indexName = foo_index
a1.sinks.k1.indexType = bar_type
a1.sinks.k1.hostNames = 127.0.0.1:9200
a1.sinks.k1.channel = c1


Diffs (updated)
-----

  flume-ng-sinks/flume-ng-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/ElasticSearchSink.java 39b6db5 

Diff: https://reviews.apache.org/r/21876/diff/


Testing
-------


Thanks,

Satoshi Iijima