You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flume.apache.org by "klaus zhou (Jira)" <ji...@apache.org> on 2022/07/14 09:25:00 UTC

[jira] [Created] (FLUME-3429) memorychannel optimization

klaus zhou created FLUME-3429:
---------------------------------

             Summary: memorychannel optimization
                 Key: FLUME-3429
                 URL: https://issues.apache.org/jira/browse/FLUME-3429
             Project: Flume
          Issue Type: Improvement
          Components: Channel
    Affects Versions: 1.10.0
            Reporter: klaus zhou
         Attachments: image-2022-07-14-17-24-03-815.png

for the memorychannel ,i found that when it comes ChannelFullException ,memorychannel  will call the doRollback,it means that putList will be clear and the takeList will be rollback;

!image-2022-07-14-17-24-03-815.png!
actually i just want to clean putList ,cuz its source wirte to channel error;
takeList will be rollback when channel to sink error。
i means that doRollback of memorychannel will be diffrenet when (source wirte to channel error)or ( channel to sink error)



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscribe@flume.apache.org
For additional commands, e-mail: issues-help@flume.apache.org