Hi, I think people will be confused by the behaviour of startNewChain() in the streaming API. I myself had wrong assumptions about how it behaves when I was writing a test Job and the only other Job where someone not coming from Streaming wrote a Streaming Test is also making wrong assumptions. (StreamCheckpointingITCase, I'm not saying that's a stupid mistake, I made the same mistake myself.)
So what chains of operators should this snipped produce: input .map(new Map1()) .map(new Map2()) .startNewChain() .map(new Map3()) .print() I would guess that your assumption about where the split in the chains happens here is wrong. :D Cheers, Aljoscha
