[ 
https://issues.apache.org/jira/browse/RATIS-141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16258728#comment-16258728
 ] 

Tsz Wo Nicholas Sze commented on RATIS-141:
-------------------------------------------

> It seems easier to reproduce the failure of TestRaftStream if the 
> AppendStreamer.LOG is turned off.

Due to this reason, it looks like that the bug is in AppendStreamer.  Consider 
that AppendStreamer is only used in rpc.client.RaftOutputStream and tests.  
Let's fix it separately; filed RATIS-149.

> In RaftClientProtocolService, the assumption of consecutive callId is invalid
> -----------------------------------------------------------------------------
>
>                 Key: RATIS-141
>                 URL: https://issues.apache.org/jira/browse/RATIS-141
>             Project: Ratis
>          Issue Type: Bug
>            Reporter: Tsz Wo Nicholas Sze
>            Assignee: Tsz Wo Nicholas Sze
>         Attachments: r141_20171117.patch
>
>
> {code}
> //RaftClientProtocolService.AppendRequestStreamObserver.onNext(..)
>               // we assume the callId is consecutive for a stream RPC call
>               final PendingAppend pendingForReply = pendingList.get(
>                   (int) (replySeq - headSeqNum));
> {code}
> Call id is used for different kinds of calls (e.g. getInfo) so that it may 
> not be consecutive.



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)

Reply via email to