I have a question around event timestamps after a flatMap transformation, I am using the event time time characteristic. I have two streams entering a CoFlatMap. Stream A simply updates state in that CoFlatMap and does not output any events. Stream B inserts events of type B which then output a third type C.
Will the event timestamp from B be propagated to C? Do I need to add an explicit timestamp assigner for C? All windowing in this topology is done on event C so my assumption was: Stream A does not need a timestamp assigner or watermark generator Stream B does not need a timestamp assigner or watermark generator Stream C needs a timestamp assigner and watermark generator The confusion as to whether event B's timestamp is propagated to event C arose from this sentence in the documentation: "Operators that consume multiple input streams (e.g., after a *keyBy(…)* or *partition(…)* function, or a union) track the event time on each of their input streams. The operator’s current event time is the minimum of the input streams’ event time. As the input streams update their event time, so does the operator." https://ci.apache.org/projects/flink/flink-docs-master/apis/streaming/event_time.html#watermarks-in-parallel-streams Thanks for your help, Chris
