flume-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Denes Arvay (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLUME-2844) ChannelCounter of SpillableMemoryChannel doesn't register actually.
Date Fri, 22 Jul 2016 15:19:20 GMT

    [ https://issues.apache.org/jira/browse/FLUME-2844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15389667#comment-15389667

Denes Arvay commented on FLUME-2844:

Hi [~sandywei], thanks for the patch. Could you please submit it to reviewboard.apache.org?
I'd be happy to review it there. Thank you.

> ChannelCounter of SpillableMemoryChannel doesn't register actually.
> -------------------------------------------------------------------
>                 Key: FLUME-2844
>                 URL: https://issues.apache.org/jira/browse/FLUME-2844
>             Project: Flume
>          Issue Type: Bug
>          Components: Channel
>    Affects Versions: v1.6.0
>            Reporter: Daniel Wen
>         Attachments: FLUME-2844.0000.patch
> When using SpillableMemoryChannel, the values of all metrics of channel component int
monitoring system is zero.It's caused by a bug belowed.
> SpillableMemoryChannel extends FileChannel,and each of them have a ChannelCounter-Type
field named of 'channelCounter'. FileChannel's channelCounter filed is private, so it can
not be override by SpillableMemoryChannel. SpillableMemoryChannel's channelCounter is initialized
in configure method(Line 600 at SpillableMemoryChannel.java), then super.configure() is called(Line
727 at SpillableMemoryChannel.java). So FileChannel's channelCounter is also initialized(Line
267 at SpillableMemoryChannel.java).
> When SpillableMemoryChannel start(call start() method), it should and want to register
ChannelCounter. In start() method, SpillableMemoryChannel calls  super.start() (Line 768 at
SpillableMemoryChannel.java), then FileChannel calls channelCounter.start() to register channelCounter.
But this channelCounter is the one of FileChannle, not the one of SpillableMemoryChannel!
> This bug results that when using SpillableMemoryChannel, the values of all metrics of
channel component is zero.
> Maybe the qualifier of FileChannel's channelCounter filed should be changed to prtected,
and remove the channelCounter filed of SpillableMemoryChannel.

This message was sent by Atlassian JIRA

View raw message