----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/51244/ -----------------------------------------------------------
(Updated Aug. 23, 2016, 2:43 p.m.) Review request for Flume. Bugs: FLUME-2171 https://issues.apache.org/jira/browse/FLUME-2171 Repository: flume-git Description ------- I found Flume OG's decorators to handle event headers useful and some to be missing from Flume NG. More specifically, we could have an interceptor to remove headers from an event. Diffs (updated) ----- c/flume-ng-core/src/main/java/org/apache/flume/interceptor/InterceptorType.java fe341e9 c/flume-ng-doc/sphinx/FlumeUserGuide.rst 5e677c6 w/flume-ng-core/src/main/java/org/apache/flume/interceptor/RemoveHeaderInterceptor.java PRE-CREATION w/flume-ng-core/src/test/java/org/apache/flume/interceptor/RemoveHeaderInterceptorTest.java PRE-CREATION Diff: https://reviews.apache.org/r/51244/diff/ Testing ------- All tests (besides the FLUME-2974-related ones) in flume-ng-core run successfully I've used this config for manual testing: a1.sources = r1 a1.sources.r1.type = netcat a1.sources.r1.bind = 0.0.0.0 a1.sources.r1.port = 6666 a1.sources.r1.channels = c1 a1.channels = c1 a1.channels.c1.type = memory a1.channels.c1.capacity = 10000 a1.channels.c1.transactionCapacity = 10000 a1.channels.c1.byteCapacityBufferPercentage = 20 a1.channels.c1.byteCapacity = 800000 a1.channels = c1 a1.sinks = k1 a1.sinks.k1.type = logger a1.sinks.k1.channel = c1 a1.sources.r1.interceptors = i1 i2 i3 a1.sources.r1.interceptors.i1.type = timestamp a1.sources.r1.interceptors.i2.type = host a1.sources.r1.interceptors.i2.hostHeader = hostname a1.sources.r1.interceptors.i3.type = remove_header a1.sources.r1.interceptors.i3.with.name = timestamp Thanks, Balázs Donát Bessenyei