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. Use arrival time for every event and discard the source timestamp.
  3. Treat the watermark as a guarantee that no earlier event can ever arrive.
  4. Define allowed lateness and trigger behavior for the windows.
  5. Assign timestamps representing when the underlying events occurred.

Comments — 0