A streaming pipeline must aggregate by business event time and account for records that arrive after the usual window completion. Which two configuration decisions directly address these requirements? Select 2 answers.

Published
  1. Increase worker count and assume it resolves all out-of-order event semantics.
  2. Assign timestamps representing when the underlying events occurred.
  3. Treat the watermark as a guarantee that no earlier event can ever arrive.
  4. Use arrival time for every event and discard the source timestamp.
  5. Define allowed lateness and trigger behavior for the windows.

Comments — 0