Improve dataflow log, add mergeInputRecords, segment=>taskId and etc.