Flume
  1. Flume
  2. FLUME-814

Add support for multiple channels to sources

    Details

    • Type: New Feature New Feature
    • Status: Closed
    • Priority: Major Major
    • Resolution: Fixed
    • Affects Version/s: NG alpha 1
    • Fix Version/s: NG alpha 2
    • Component/s: Sinks+Sources
    • Labels:
      None

      Description

      Flume NG's architecture and configuration claim sources support multiple channels but this isn't currently true. The current implementation limits sources to a single channel which precludes fanout behavior.

      This will be a fairly invasive change as it impacts the Source interface.

      1. FLUME-814.patch
        13 kB
        Prasad Mujumdar

        Activity

        E. Sammer created issue -
        Prasad Mujumdar made changes -
        Field Original Value New Value
        Assignee Prasad Mujumdar [ prasadm ]
        Hide
        jiraposter@reviews.apache.org added a comment -

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

        Review request for Arvind Prabhakar and Eric Sammer.

        Summary
        -------

        A new fanout channel is added that contains list of underlying channels and performs the given operation on all those. A new method added to channelfactory to create the fanout channel from a list of channels. One can specify a comma separated list of channels for a sink to create the fanout

        This addresses bug Flume-814.
        https://issues.apache.org/jira/browse/Flume-814

        Diffs


        flume-ng-core/src/main/java/org/apache/flume/ChannelFactory.java 23194a9
        flume-ng-core/src/main/java/org/apache/flume/channel/DefaultChannelFactory.java a41085f
        flume-ng-core/src/main/java/org/apache/flume/channel/FanoutChannel.java PRE-CREATION
        flume-ng-core/src/test/java/org/apache/flume/channel/TestFanoutChannel.java PRE-CREATION
        flume-ng-node/src/main/java/org/apache/flume/conf/properties/PropertiesFileConfigurationProvider.java 975eafd
        flume-ng-node/src/main/java/org/apache/flume/node/Application.java 4004cba

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

        Testing
        -------

        ran all unit tests, added new test for the fanout channel

        Thanks,

        Prasad

        Show
        jiraposter@reviews.apache.org added a comment - ----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/2701/ ----------------------------------------------------------- Review request for Arvind Prabhakar and Eric Sammer. Summary ------- A new fanout channel is added that contains list of underlying channels and performs the given operation on all those. A new method added to channelfactory to create the fanout channel from a list of channels. One can specify a comma separated list of channels for a sink to create the fanout This addresses bug Flume-814. https://issues.apache.org/jira/browse/Flume-814 Diffs flume-ng-core/src/main/java/org/apache/flume/ChannelFactory.java 23194a9 flume-ng-core/src/main/java/org/apache/flume/channel/DefaultChannelFactory.java a41085f flume-ng-core/src/main/java/org/apache/flume/channel/FanoutChannel.java PRE-CREATION flume-ng-core/src/test/java/org/apache/flume/channel/TestFanoutChannel.java PRE-CREATION flume-ng-node/src/main/java/org/apache/flume/conf/properties/PropertiesFileConfigurationProvider.java 975eafd flume-ng-node/src/main/java/org/apache/flume/node/Application.java 4004cba Diff: https://reviews.apache.org/r/2701/diff Testing ------- ran all unit tests, added new test for the fanout channel Thanks, Prasad
        Hide
        jiraposter@reviews.apache.org added a comment -

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

        This is probably a nicer approach than what we originally discussed; having the source take a list of channels. My concern is the implementation of take(). To take another step back, it actually doesn't make sense to take from a fan out channel at all. If we follow this path toward fan out functionality, should we instead throw UnsupportedOperationException from take() and disallow the (otherwise odd) behavior of discarding messages from the fan out?

        I can't think of any, but does this affect the failure scenarios in any way? We know we're not atomic across channels but are there any other concerns here?

        I have some naming / implementation nits, but otherwise I think this makes sense provided I can convince myself we're not doing anything bad here.

        • Eric

        On 2011-11-03 05:13:00, Prasad Mujumdar wrote:

        -----------------------------------------------------------

        This is an automatically generated e-mail. To reply, visit:

        https://reviews.apache.org/r/2701/

        -----------------------------------------------------------

        (Updated 2011-11-03 05:13:00)

        Review request for Arvind Prabhakar and Eric Sammer.

        Summary

        -------

        A new fanout channel is added that contains list of underlying channels and performs the given operation on all those. A new method added to channelfactory to create the fanout channel from a list of channels. One can specify a comma separated list of channels for a sink to create the fanout

        This addresses bug Flume-814.

        https://issues.apache.org/jira/browse/Flume-814

        Diffs

        -----

        flume-ng-core/src/main/java/org/apache/flume/ChannelFactory.java 23194a9

        flume-ng-core/src/main/java/org/apache/flume/channel/DefaultChannelFactory.java a41085f

        flume-ng-core/src/main/java/org/apache/flume/channel/FanoutChannel.java PRE-CREATION

        flume-ng-core/src/test/java/org/apache/flume/channel/TestFanoutChannel.java PRE-CREATION

        flume-ng-node/src/main/java/org/apache/flume/conf/properties/PropertiesFileConfigurationProvider.java 975eafd

        flume-ng-node/src/main/java/org/apache/flume/node/Application.java 4004cba

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

        Testing

        -------

        ran all unit tests, added new test for the fanout channel

        Thanks,

        Prasad

        Show
        jiraposter@reviews.apache.org added a comment - ----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/2701/#review3026 ----------------------------------------------------------- This is probably a nicer approach than what we originally discussed; having the source take a list of channels. My concern is the implementation of take(). To take another step back, it actually doesn't make sense to take from a fan out channel at all. If we follow this path toward fan out functionality, should we instead throw UnsupportedOperationException from take() and disallow the (otherwise odd) behavior of discarding messages from the fan out? I can't think of any, but does this affect the failure scenarios in any way? We know we're not atomic across channels but are there any other concerns here? I have some naming / implementation nits, but otherwise I think this makes sense provided I can convince myself we're not doing anything bad here. Eric On 2011-11-03 05:13:00, Prasad Mujumdar wrote: ----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/2701/ ----------------------------------------------------------- (Updated 2011-11-03 05:13:00) Review request for Arvind Prabhakar and Eric Sammer. Summary ------- A new fanout channel is added that contains list of underlying channels and performs the given operation on all those. A new method added to channelfactory to create the fanout channel from a list of channels. One can specify a comma separated list of channels for a sink to create the fanout This addresses bug Flume-814. https://issues.apache.org/jira/browse/Flume-814 Diffs ----- flume-ng-core/src/main/java/org/apache/flume/ChannelFactory.java 23194a9 flume-ng-core/src/main/java/org/apache/flume/channel/DefaultChannelFactory.java a41085f flume-ng-core/src/main/java/org/apache/flume/channel/FanoutChannel.java PRE-CREATION flume-ng-core/src/test/java/org/apache/flume/channel/TestFanoutChannel.java PRE-CREATION flume-ng-node/src/main/java/org/apache/flume/conf/properties/PropertiesFileConfigurationProvider.java 975eafd flume-ng-node/src/main/java/org/apache/flume/node/Application.java 4004cba Diff: https://reviews.apache.org/r/2701/diff Testing ------- ran all unit tests, added new test for the fanout channel Thanks, Prasad
        Hide
        jiraposter@reviews.apache.org added a comment -

        On 2011-11-03 15:58:19, Eric Sammer wrote:

        > This is probably a nicer approach than what we originally discussed; having the source take a list of channels. My concern is the implementation of take(). To take another step back, it actually doesn't make sense to take from a fan out channel at all. If we follow this path toward fan out functionality, should we instead throw UnsupportedOperationException from take() and disallow the (otherwise odd) behavior of discarding messages from the fan out?

        >

        > I can't think of any, but does this affect the failure scenarios in any way? We know we're not atomic across channels but are there any other concerns here?

        >

        > I have some naming / implementation nits, but otherwise I think this makes sense provided I can convince myself we're not doing anything bad here.

        I agree about the take. The only reason I implemented it that way is for tests. In fact my original approach was to add a fanout channel by default to every sink. Most of the existing tests would have run into problems if it doesn't have put(). With the current approach, we can safely disable talk(). I will go ahead and make that change.
        Please let me know your other comments, I would like to address those as well.

        thanks
        Prasad

        • Prasad

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

        On 2011-11-03 05:13:00, Prasad Mujumdar wrote:

        -----------------------------------------------------------

        This is an automatically generated e-mail. To reply, visit:

        https://reviews.apache.org/r/2701/

        -----------------------------------------------------------

        (Updated 2011-11-03 05:13:00)

        Review request for Arvind Prabhakar and Eric Sammer.

        Summary

        -------

        A new fanout channel is added that contains list of underlying channels and performs the given operation on all those. A new method added to channelfactory to create the fanout channel from a list of channels. One can specify a comma separated list of channels for a sink to create the fanout

        This addresses bug Flume-814.

        https://issues.apache.org/jira/browse/Flume-814

        Diffs

        -----

        flume-ng-core/src/main/java/org/apache/flume/ChannelFactory.java 23194a9

        flume-ng-core/src/main/java/org/apache/flume/channel/DefaultChannelFactory.java a41085f

        flume-ng-core/src/main/java/org/apache/flume/channel/FanoutChannel.java PRE-CREATION

        flume-ng-core/src/test/java/org/apache/flume/channel/TestFanoutChannel.java PRE-CREATION

        flume-ng-node/src/main/java/org/apache/flume/conf/properties/PropertiesFileConfigurationProvider.java 975eafd

        flume-ng-node/src/main/java/org/apache/flume/node/Application.java 4004cba

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

        Testing

        -------

        ran all unit tests, added new test for the fanout channel

        Thanks,

        Prasad

        Show
        jiraposter@reviews.apache.org added a comment - On 2011-11-03 15:58:19, Eric Sammer wrote: > This is probably a nicer approach than what we originally discussed; having the source take a list of channels. My concern is the implementation of take(). To take another step back, it actually doesn't make sense to take from a fan out channel at all. If we follow this path toward fan out functionality, should we instead throw UnsupportedOperationException from take() and disallow the (otherwise odd) behavior of discarding messages from the fan out? > > I can't think of any, but does this affect the failure scenarios in any way? We know we're not atomic across channels but are there any other concerns here? > > I have some naming / implementation nits, but otherwise I think this makes sense provided I can convince myself we're not doing anything bad here. I agree about the take. The only reason I implemented it that way is for tests. In fact my original approach was to add a fanout channel by default to every sink. Most of the existing tests would have run into problems if it doesn't have put(). With the current approach, we can safely disable talk(). I will go ahead and make that change. Please let me know your other comments, I would like to address those as well. thanks Prasad Prasad ----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/2701/#review3026 ----------------------------------------------------------- On 2011-11-03 05:13:00, Prasad Mujumdar wrote: ----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/2701/ ----------------------------------------------------------- (Updated 2011-11-03 05:13:00) Review request for Arvind Prabhakar and Eric Sammer. Summary ------- A new fanout channel is added that contains list of underlying channels and performs the given operation on all those. A new method added to channelfactory to create the fanout channel from a list of channels. One can specify a comma separated list of channels for a sink to create the fanout This addresses bug Flume-814. https://issues.apache.org/jira/browse/Flume-814 Diffs ----- flume-ng-core/src/main/java/org/apache/flume/ChannelFactory.java 23194a9 flume-ng-core/src/main/java/org/apache/flume/channel/DefaultChannelFactory.java a41085f flume-ng-core/src/main/java/org/apache/flume/channel/FanoutChannel.java PRE-CREATION flume-ng-core/src/test/java/org/apache/flume/channel/TestFanoutChannel.java PRE-CREATION flume-ng-node/src/main/java/org/apache/flume/conf/properties/PropertiesFileConfigurationProvider.java 975eafd flume-ng-node/src/main/java/org/apache/flume/node/Application.java 4004cba Diff: https://reviews.apache.org/r/2701/diff Testing ------- ran all unit tests, added new test for the fanout channel Thanks, Prasad
        Hide
        jiraposter@reviews.apache.org added a comment -

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

        (Updated 2011-11-03 22:57:15.522159)

        Review request for Arvind Prabhakar and Eric Sammer.

        Changes
        -------

        Changed take() to throw exception always. Added more error handling for fanout transaction and test cases.

        Summary
        -------

        A new fanout channel is added that contains list of underlying channels and performs the given operation on all those. A new method added to channelfactory to create the fanout channel from a list of channels. One can specify a comma separated list of channels for a sink to create the fanout

        This addresses bug Flume-814.
        https://issues.apache.org/jira/browse/Flume-814

        Diffs (updated)


        flume-ng-core/src/main/java/org/apache/flume/ChannelFactory.java 23194a9
        flume-ng-core/src/main/java/org/apache/flume/channel/DefaultChannelFactory.java a41085f
        flume-ng-core/src/main/java/org/apache/flume/channel/FanoutChannel.java PRE-CREATION
        flume-ng-core/src/main/java/org/apache/flume/channel/MemoryChannel.java 4d8313f
        flume-ng-core/src/test/java/org/apache/flume/channel/TestFanoutChannel.java PRE-CREATION
        flume-ng-node/src/main/java/org/apache/flume/conf/properties/PropertiesFileConfigurationProvider.java 975eafd
        flume-ng-node/src/main/java/org/apache/flume/node/Application.java 4004cba

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

        Testing
        -------

        ran all unit tests, added new test for the fanout channel

        Thanks,

        Prasad

        Show
        jiraposter@reviews.apache.org added a comment - ----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/2701/ ----------------------------------------------------------- (Updated 2011-11-03 22:57:15.522159) Review request for Arvind Prabhakar and Eric Sammer. Changes ------- Changed take() to throw exception always. Added more error handling for fanout transaction and test cases. Summary ------- A new fanout channel is added that contains list of underlying channels and performs the given operation on all those. A new method added to channelfactory to create the fanout channel from a list of channels. One can specify a comma separated list of channels for a sink to create the fanout This addresses bug Flume-814. https://issues.apache.org/jira/browse/Flume-814 Diffs (updated) flume-ng-core/src/main/java/org/apache/flume/ChannelFactory.java 23194a9 flume-ng-core/src/main/java/org/apache/flume/channel/DefaultChannelFactory.java a41085f flume-ng-core/src/main/java/org/apache/flume/channel/FanoutChannel.java PRE-CREATION flume-ng-core/src/main/java/org/apache/flume/channel/MemoryChannel.java 4d8313f flume-ng-core/src/test/java/org/apache/flume/channel/TestFanoutChannel.java PRE-CREATION flume-ng-node/src/main/java/org/apache/flume/conf/properties/PropertiesFileConfigurationProvider.java 975eafd flume-ng-node/src/main/java/org/apache/flume/node/Application.java 4004cba Diff: https://reviews.apache.org/r/2701/diff Testing ------- ran all unit tests, added new test for the fanout channel Thanks, Prasad
        Prasad Mujumdar made changes -
        Attachment FLUME-814.patch [ 12502543 ]
        Prasad Mujumdar made changes -
        Status Open [ 1 ] Patch Available [ 10002 ]
        Hide
        jiraposter@reviews.apache.org added a comment -

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

        Ship it!

        Hi Prasad, my apologies for jumping in late on this review. I have some feedback below. Considering the time elapsed on this issue, I am ok with going ahead with the commit and opening follow-up JIRAs to track the issues highlighted.

        flume-ng-core/src/main/java/org/apache/flume/channel/FanoutChannel.java
        <https://reviews.apache.org/r/2701/#comment7998>

        This can lead to inconsistencies. Calling a roll-back (or any other method) on a transaction that has not yet begun could lead to leaks.

        flume-ng-core/src/main/java/org/apache/flume/channel/FanoutChannel.java
        <https://reviews.apache.org/r/2701/#comment7999>

        Same as before - calling a close on a transaction that has not begun will lead to other problems.

        • Arvind

        On 2011-11-03 22:57:15, Prasad Mujumdar wrote:

        -----------------------------------------------------------

        This is an automatically generated e-mail. To reply, visit:

        https://reviews.apache.org/r/2701/

        -----------------------------------------------------------

        (Updated 2011-11-03 22:57:15)

        Review request for Arvind Prabhakar and Eric Sammer.

        Summary

        -------

        A new fanout channel is added that contains list of underlying channels and performs the given operation on all those. A new method added to channelfactory to create the fanout channel from a list of channels. One can specify a comma separated list of channels for a sink to create the fanout

        This addresses bug Flume-814.

        https://issues.apache.org/jira/browse/Flume-814

        Diffs

        -----

        flume-ng-core/src/main/java/org/apache/flume/ChannelFactory.java 23194a9

        flume-ng-core/src/main/java/org/apache/flume/channel/DefaultChannelFactory.java a41085f

        flume-ng-core/src/main/java/org/apache/flume/channel/FanoutChannel.java PRE-CREATION

        flume-ng-core/src/main/java/org/apache/flume/channel/MemoryChannel.java 4d8313f

        flume-ng-core/src/test/java/org/apache/flume/channel/TestFanoutChannel.java PRE-CREATION

        flume-ng-node/src/main/java/org/apache/flume/conf/properties/PropertiesFileConfigurationProvider.java 975eafd

        flume-ng-node/src/main/java/org/apache/flume/node/Application.java 4004cba

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

        Testing

        -------

        ran all unit tests, added new test for the fanout channel

        Thanks,

        Prasad

        Show
        jiraposter@reviews.apache.org added a comment - ----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/2701/#review3586 ----------------------------------------------------------- Ship it! Hi Prasad, my apologies for jumping in late on this review. I have some feedback below. Considering the time elapsed on this issue, I am ok with going ahead with the commit and opening follow-up JIRAs to track the issues highlighted. flume-ng-core/src/main/java/org/apache/flume/channel/FanoutChannel.java < https://reviews.apache.org/r/2701/#comment7998 > This can lead to inconsistencies. Calling a roll-back (or any other method) on a transaction that has not yet begun could lead to leaks. flume-ng-core/src/main/java/org/apache/flume/channel/FanoutChannel.java < https://reviews.apache.org/r/2701/#comment7999 > Same as before - calling a close on a transaction that has not begun will lead to other problems. Arvind On 2011-11-03 22:57:15, Prasad Mujumdar wrote: ----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/2701/ ----------------------------------------------------------- (Updated 2011-11-03 22:57:15) Review request for Arvind Prabhakar and Eric Sammer. Summary ------- A new fanout channel is added that contains list of underlying channels and performs the given operation on all those. A new method added to channelfactory to create the fanout channel from a list of channels. One can specify a comma separated list of channels for a sink to create the fanout This addresses bug Flume-814. https://issues.apache.org/jira/browse/Flume-814 Diffs ----- flume-ng-core/src/main/java/org/apache/flume/ChannelFactory.java 23194a9 flume-ng-core/src/main/java/org/apache/flume/channel/DefaultChannelFactory.java a41085f flume-ng-core/src/main/java/org/apache/flume/channel/FanoutChannel.java PRE-CREATION flume-ng-core/src/main/java/org/apache/flume/channel/MemoryChannel.java 4d8313f flume-ng-core/src/test/java/org/apache/flume/channel/TestFanoutChannel.java PRE-CREATION flume-ng-node/src/main/java/org/apache/flume/conf/properties/PropertiesFileConfigurationProvider.java 975eafd flume-ng-node/src/main/java/org/apache/flume/node/Application.java 4004cba Diff: https://reviews.apache.org/r/2701/diff Testing ------- ran all unit tests, added new test for the fanout channel Thanks, Prasad
        Hide
        jiraposter@reviews.apache.org added a comment -

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

        (Updated 2011-12-01 00:22:45.995318)

        Review request for Arvind Prabhakar and Eric Sammer.

        Changes
        -------

        Update the patch to maintain consistent state for enclosed transactions in error cases.

        Summary
        -------

        A new fanout channel is added that contains list of underlying channels and performs the given operation on all those. A new method added to channelfactory to create the fanout channel from a list of channels. One can specify a comma separated list of channels for a sink to create the fanout

        This addresses bug Flume-814.
        https://issues.apache.org/jira/browse/Flume-814

        Diffs (updated)


        flume-ng-core/src/main/java/org/apache/flume/ChannelFactory.java 23194a9
        flume-ng-core/src/main/java/org/apache/flume/channel/DefaultChannelFactory.java 8a3ec56
        flume-ng-core/src/main/java/org/apache/flume/channel/FanoutChannel.java PRE-CREATION
        flume-ng-core/src/main/java/org/apache/flume/channel/MemoryChannel.java 4d8313f
        flume-ng-core/src/test/java/org/apache/flume/channel/TestFanoutChannel.java PRE-CREATION
        flume-ng-node/src/main/java/org/apache/flume/conf/properties/PropertiesFileConfigurationProvider.java 975eafd
        flume-ng-node/src/main/java/org/apache/flume/node/Application.java 8b93e59

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

        Testing
        -------

        ran all unit tests, added new test for the fanout channel

        Thanks,

        Prasad

        Show
        jiraposter@reviews.apache.org added a comment - ----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/2701/ ----------------------------------------------------------- (Updated 2011-12-01 00:22:45.995318) Review request for Arvind Prabhakar and Eric Sammer. Changes ------- Update the patch to maintain consistent state for enclosed transactions in error cases. Summary ------- A new fanout channel is added that contains list of underlying channels and performs the given operation on all those. A new method added to channelfactory to create the fanout channel from a list of channels. One can specify a comma separated list of channels for a sink to create the fanout This addresses bug Flume-814. https://issues.apache.org/jira/browse/Flume-814 Diffs (updated) flume-ng-core/src/main/java/org/apache/flume/ChannelFactory.java 23194a9 flume-ng-core/src/main/java/org/apache/flume/channel/DefaultChannelFactory.java 8a3ec56 flume-ng-core/src/main/java/org/apache/flume/channel/FanoutChannel.java PRE-CREATION flume-ng-core/src/main/java/org/apache/flume/channel/MemoryChannel.java 4d8313f flume-ng-core/src/test/java/org/apache/flume/channel/TestFanoutChannel.java PRE-CREATION flume-ng-node/src/main/java/org/apache/flume/conf/properties/PropertiesFileConfigurationProvider.java 975eafd flume-ng-node/src/main/java/org/apache/flume/node/Application.java 8b93e59 Diff: https://reviews.apache.org/r/2701/diff Testing ------- ran all unit tests, added new test for the fanout channel Thanks, Prasad
        Hide
        Prasad Mujumdar added a comment -

        Committed to flume-728

        Show
        Prasad Mujumdar added a comment - Committed to flume-728
        Prasad Mujumdar made changes -
        Status Patch Available [ 10002 ] Resolved [ 5 ]
        Resolution Fixed [ 1 ]
        Hide
        Hudson added a comment -

        Integrated in flume-728 #64 (See https://builds.apache.org/job/flume-728/64/)
        Flume-814. Fanout channel support

        Show
        Hudson added a comment - Integrated in flume-728 #64 (See https://builds.apache.org/job/flume-728/64/ ) Flume-814. Fanout channel support
        E. Sammer made changes -
        Status Resolved [ 5 ] Closed [ 6 ]

          People

          • Assignee:
            Prasad Mujumdar
            Reporter:
            E. Sammer
          • Votes:
            1 Vote for this issue
            Watchers:
            0 Start watching this issue

            Dates

            • Created:
              Updated:
              Resolved:

              Development