[
https://issues.apache.org/jira/browse/FLUME-942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13199032#comment-13199032
]
[email protected] commented on FLUME-942:
-----------------------------------------------------
-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/3701/
-----------------------------------------------------------
(Updated 2012-02-02 17:57:05.688637)
Review request for Flume and Eric Sammer.
Changes
-------
The java code generated by thrift compiler is checked. Also added a maven
profiles to allow thrift compilation. Renamed some of the modulues/files to
remove OG, NG references.
Summary
-------
Added thrift and sources to process flume-og thrift event formats.
Flume OG clients can send events directly to these NG sources. Also Flume OG
agents can configure the rcpSinks to send events to these NG sinks.
This addresses bug FLUME-942.
https://issues.apache.org/jira/browse/FLUME-942
Diffs (updated)
-----
flume-ng-legacy-sources/flume-avro-source/pom.xml PRE-CREATION
flume-ng-legacy-sources/flume-avro-source/src/main/avro/flumeCompatibility.avdl
PRE-CREATION
flume-ng-legacy-sources/flume-avro-source/src/main/java/org/apache/flume/source/avroOG/AvroOGSource.java
PRE-CREATION
flume-ng-legacy-sources/flume-avro-source/src/test/java/org/apache/flume/source/avroOG/TestOGAvroSource.java
PRE-CREATION
flume-ng-legacy-sources/flume-thrift-source/pom.xml PRE-CREATION
flume-ng-legacy-sources/flume-thrift-source/src/main/java/README PRE-CREATION
flume-ng-legacy-sources/flume-thrift-source/src/main/java/com/cloudera/flume/handlers/thrift/EventStatus.java
PRE-CREATION
flume-ng-legacy-sources/flume-thrift-source/src/main/java/com/cloudera/flume/handlers/thrift/Priority.java
PRE-CREATION
flume-ng-legacy-sources/flume-thrift-source/src/main/java/com/cloudera/flume/handlers/thrift/ThriftFlumeEvent.java
PRE-CREATION
flume-ng-legacy-sources/flume-thrift-source/src/main/java/com/cloudera/flume/handlers/thrift/ThriftFlumeEventServer.java
PRE-CREATION
flume-ng-legacy-sources/flume-thrift-source/src/main/java/org/apache/flume/source/thrift/ThriftCompatibilitySource.java
PRE-CREATION
flume-ng-legacy-sources/flume-thrift-source/src/main/thrift/flumeCompatibility.thrift
PRE-CREATION
flume-ng-legacy-sources/flume-thrift-source/src/test/java/org/apache/flume/source/thriftOG/TestThriftOGSource.java
PRE-CREATION
flume-ng-legacy-sources/pom.xml PRE-CREATION
pom.xml 2bf32bb
Diff: https://reviews.apache.org/r/3701/diff
Testing
-------
Regression tests
Added tests for the new sinks
Manually tested event transfer from OG agents to NG thrift and avro sources.
Thanks,
Prasad
> Support event compatibility with Flume 0.9x
> -------------------------------------------
>
> Key: FLUME-942
> URL: https://issues.apache.org/jira/browse/FLUME-942
> Project: Flume
> Issue Type: New Feature
> Components: Sinks+Sources
> Affects Versions: v1.0.0
> Reporter: Prasad Mujumdar
> Assignee: Prasad Mujumdar
>
> Support a thrift and avro source that accepts event from flume 0.9x and
> forwards it to Flume NG event flow.
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators:
https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
