Some fixes to stream processing