Add FlowId to mapper / reducer functions