You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flume.apache.org by Hari Shreedharan <hs...@cloudera.com> on 2012/02/24 19:44:34 UTC
Review Request: Support for optional channels in MultiplexingChannelSelector
-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/4034/
-----------------------------------------------------------
Review request for Flume.
Summary
-------
Support for optional channels in multiplexing channel selector. If no required channels configured, but there are optional channels then it means, write to default channels and optionally write to optional channels if they are available.
This addresses bug FLUME-946.
https://issues.apache.org/jira/browse/FLUME-946
Diffs
-----
flume-ng-core/src/main/java/org/apache/flume/channel/MultiplexingChannelSelector.java c63d0a1
flume-ng-core/src/test/java/org/apache/flume/channel/TestMultiplexingChannelSelector.java 2626b20
Diff: https://reviews.apache.org/r/4034/diff
Testing
-------
Updated unit tests to support these cases
Thanks,
Hari
Re: Review Request: Support for optional channels in
MultiplexingChannelSelector
Posted by Hari Shreedharan <hs...@cloudera.com>.
-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/4034/#review12885
-----------------------------------------------------------
flume-ng-core/src/main/java/org/apache/flume/channel/MultiplexingChannelSelector.java
<https://reviews.apache.org/r/4034/#comment27697>
Collections.EmptyList() is smarter in the sense that it is a single immutable list that is (re-)used - allowing the original list to be garbage collected immediately.
- Hari Shreedharan
On Oct. 29, 2012, 7:18 p.m., Hari Shreedharan wrote:
>
> -----------------------------------------------------------
> This is an automatically generated e-mail. To reply, visit:
> https://reviews.apache.org/r/4034/
> -----------------------------------------------------------
>
> (Updated Oct. 29, 2012, 7:18 p.m.)
>
>
> Review request for Flume.
>
>
> Description
> -------
>
> Support for optional channels in multiplexing channel selector. If no required channels configured, but there are optional channels then it means, write to default channels and optionally write to optional channels if they are available.
>
>
> This addresses bug FLUME-946.
> https://issues.apache.org/jira/browse/FLUME-946
>
>
> Diffs
> -----
>
> flume-ng-core/src/main/java/org/apache/flume/channel/MultiplexingChannelSelector.java 81dc3e8
> flume-ng-core/src/test/java/org/apache/flume/channel/TestMultiplexingChannelSelector.java 2626b20
> flume-ng-doc/sphinx/FlumeUserGuide.rst 0c0951b
>
> Diff: https://reviews.apache.org/r/4034/diff/
>
>
> Testing
> -------
>
> Updated unit tests to support these cases
>
>
> Thanks,
>
> Hari Shreedharan
>
>
Re: Review Request: Support for optional channels in
MultiplexingChannelSelector
Posted by Brock Noland <br...@cloudera.com>.
-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/4034/#review12886
-----------------------------------------------------------
Ship it!
Ship It!
- Brock Noland
On Oct. 29, 2012, 7:18 p.m., Hari Shreedharan wrote:
>
> -----------------------------------------------------------
> This is an automatically generated e-mail. To reply, visit:
> https://reviews.apache.org/r/4034/
> -----------------------------------------------------------
>
> (Updated Oct. 29, 2012, 7:18 p.m.)
>
>
> Review request for Flume.
>
>
> Description
> -------
>
> Support for optional channels in multiplexing channel selector. If no required channels configured, but there are optional channels then it means, write to default channels and optionally write to optional channels if they are available.
>
>
> This addresses bug FLUME-946.
> https://issues.apache.org/jira/browse/FLUME-946
>
>
> Diffs
> -----
>
> flume-ng-core/src/main/java/org/apache/flume/channel/MultiplexingChannelSelector.java 81dc3e8
> flume-ng-core/src/test/java/org/apache/flume/channel/TestMultiplexingChannelSelector.java 2626b20
> flume-ng-doc/sphinx/FlumeUserGuide.rst 0c0951b
>
> Diff: https://reviews.apache.org/r/4034/diff/
>
>
> Testing
> -------
>
> Updated unit tests to support these cases
>
>
> Thanks,
>
> Hari Shreedharan
>
>
Re: Review Request: Support for optional channels in
MultiplexingChannelSelector
Posted by Brock Noland <br...@cloudera.com>.
-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/4034/#review12881
-----------------------------------------------------------
Looks good, just small item below
flume-ng-core/src/main/java/org/apache/flume/channel/MultiplexingChannelSelector.java
<https://reviews.apache.org/r/4034/#comment27689>
Why do we re-assign if empty?
- Brock Noland
On Oct. 29, 2012, 7:18 p.m., Hari Shreedharan wrote:
>
> -----------------------------------------------------------
> This is an automatically generated e-mail. To reply, visit:
> https://reviews.apache.org/r/4034/
> -----------------------------------------------------------
>
> (Updated Oct. 29, 2012, 7:18 p.m.)
>
>
> Review request for Flume.
>
>
> Description
> -------
>
> Support for optional channels in multiplexing channel selector. If no required channels configured, but there are optional channels then it means, write to default channels and optionally write to optional channels if they are available.
>
>
> This addresses bug FLUME-946.
> https://issues.apache.org/jira/browse/FLUME-946
>
>
> Diffs
> -----
>
> flume-ng-core/src/main/java/org/apache/flume/channel/MultiplexingChannelSelector.java 81dc3e8
> flume-ng-core/src/test/java/org/apache/flume/channel/TestMultiplexingChannelSelector.java 2626b20
> flume-ng-doc/sphinx/FlumeUserGuide.rst 0c0951b
>
> Diff: https://reviews.apache.org/r/4034/diff/
>
>
> Testing
> -------
>
> Updated unit tests to support these cases
>
>
> Thanks,
>
> Hari Shreedharan
>
>
Re: Review Request: Support for optional channels in
MultiplexingChannelSelector
Posted by Hari Shreedharan <hs...@cloudera.com>.
-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/4034/
-----------------------------------------------------------
(Updated Oct. 29, 2012, 7:18 p.m.)
Review request for Flume.
Changes
-------
Rebased, made some updates.
Description
-------
Support for optional channels in multiplexing channel selector. If no required channels configured, but there are optional channels then it means, write to default channels and optionally write to optional channels if they are available.
This addresses bug FLUME-946.
https://issues.apache.org/jira/browse/FLUME-946
Diffs (updated)
-----
flume-ng-core/src/main/java/org/apache/flume/channel/MultiplexingChannelSelector.java 81dc3e8
flume-ng-core/src/test/java/org/apache/flume/channel/TestMultiplexingChannelSelector.java 2626b20
flume-ng-doc/sphinx/FlumeUserGuide.rst 0c0951b
Diff: https://reviews.apache.org/r/4034/diff/
Testing
-------
Updated unit tests to support these cases
Thanks,
Hari Shreedharan
Re: Review Request: Support for optional channels in
MultiplexingChannelSelector
Posted by Brock Noland <br...@cloudera.com>.
-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/4034/#review12874
-----------------------------------------------------------
Hi,
The patch fails to apply. Can you rebase it?
patching file flume-ng-core/src/main/java/org/apache/flume/channel/MultiplexingChannelSelector.java
Hunk #1 FAILED at 38.
Hunk #4 succeeded at 119 (offset -1 lines).
1 out of 4 hunks FAILED -- saving rejects to file flume-ng-core/src/main/java/org/apache/flume/channel/MultiplexingChannelSelector.java.rej
patching file flume-ng-core/src/test/java/org/apache/flume/channel/TestMultiplexingChannelSelector.java
- Brock Noland
On Feb. 24, 2012, 7 p.m., Hari Shreedharan wrote:
>
> -----------------------------------------------------------
> This is an automatically generated e-mail. To reply, visit:
> https://reviews.apache.org/r/4034/
> -----------------------------------------------------------
>
> (Updated Feb. 24, 2012, 7 p.m.)
>
>
> Review request for Flume.
>
>
> Description
> -------
>
> Support for optional channels in multiplexing channel selector. If no required channels configured, but there are optional channels then it means, write to default channels and optionally write to optional channels if they are available.
>
>
> This addresses bug FLUME-946.
> https://issues.apache.org/jira/browse/FLUME-946
>
>
> Diffs
> -----
>
> flume-ng-core/src/main/java/org/apache/flume/channel/MultiplexingChannelSelector.java c63d0a1
> flume-ng-core/src/test/java/org/apache/flume/channel/TestMultiplexingChannelSelector.java 2626b20
>
> Diff: https://reviews.apache.org/r/4034/diff/
>
>
> Testing
> -------
>
> Updated unit tests to support these cases
>
>
> Thanks,
>
> Hari Shreedharan
>
>
Re: Review Request: Support for optional channels in
MultiplexingChannelSelector
Posted by Hari Shreedharan <hs...@cloudera.com>.
-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/4034/
-----------------------------------------------------------
(Updated 2012-02-24 19:00:14.512832)
Review request for Flume.
Changes
-------
Updated unit test to get optional channel from an event which does not have required channels.
Summary
-------
Support for optional channels in multiplexing channel selector. If no required channels configured, but there are optional channels then it means, write to default channels and optionally write to optional channels if they are available.
This addresses bug FLUME-946.
https://issues.apache.org/jira/browse/FLUME-946
Diffs (updated)
-----
flume-ng-core/src/main/java/org/apache/flume/channel/MultiplexingChannelSelector.java c63d0a1
flume-ng-core/src/test/java/org/apache/flume/channel/TestMultiplexingChannelSelector.java 2626b20
Diff: https://reviews.apache.org/r/4034/diff
Testing
-------
Updated unit tests to support these cases
Thanks,
Hari