答复: a question about CopyingChainOutput

2016-03-16 Thread Ma GuoWei
. Therefore, the “setKeyContextElement1” call is currently unnecessary. If you want you can open an issue for that and work on removing it. Cheers, Aljoscha > On 16 Mar 2016, at 09:24, Ma GuoWei wrote: > > hi,all > The class CopyingChainOutput always setKeyContextElement1 bu

a question about CopyingChainOutput

2016-03-16 Thread Ma GuoWei
hi,all The class CopyingChainOutput always setKeyContextElement1 but the second operator of "chain" is not keyedstream any more. I think this is no use to setKeyContextElement1. do i miss something? thanks for any help. [cid:df592875-6061-4929-adf8-837d47dc2afd]

Re: a question about operatorChain.broadcastCheckpointBarrier

2016-03-10 Thread Ma GuoWei
Forwards Checkpoint Barrier > Source Performs Checkpoint > > Now, both the checkpoint in the source and the checkpoints of downstream > operations correctly say that elements 13 and 14 are reflected in state > changes. > > I hope this helps but let me know if you need to kno

a question about operatorChain.broadcastCheckpointBarrier

2016-03-09 Thread Ma GuoWei
hi,all Why does the broadcastCheckpointBarrier need in the lock scope? thanks a lot. [cid:3612d450-1757-4dcb-9bb5-0d0cd8b89b1a]