1. Watermarks & Late Data advanced

    A streaming aggregation must produce results promptly while some events arrive minutes late. How do watermarks, windowing and allowed lateness interact, and what is the business decision underneath?

    2 min answer flinkwatermarkswindowinglate-data
  2. Watermarks & Late Data advanced

    Mobile clients buffer events offline and deliver them hours later. How should watermarks and late data be handled?

    2 min answer watermarkslate-datamobilecorrectness
  3. Watermarks & Late Data advanced

    Your streaming aggregate reports 2% lower daily revenue than the batch reconciliation. Both are "correct". Explain what is happening and how you resolve it.

    2 min answer streamingwatermarkslate-datacorrectness
  4. Windowing intermediate

    A live dashboard's "views in the last 30 minutes" reads about 30 times the true number. The job emits a 30-minute window advancing every minute; individual window values look correct when spot-checked; the sink is a time-series table and the panel sums the rows in the selected range. Lag and CPU are normal. What is happening and what do you change?

    3 min answer windowinghopping windowsdouble countingsinks
  5. Windowing advanced

    Surge pricing must reflect supply and demand from seconds ago, apply consistently to everyone in an area, and never change mid-request. What is the architecture?

    2 min answer uberpricingstreamingconsistency
  6. Windowing advanced

    Which windowing strategy fits which metric, and what is the property that breaks naive windowing?

    2 min answer windowingtumblingslidingsession
  7. Windowing advanced

    You implement session windows for user activity analysis. Downstream reports keep changing after publication. Explain.

    2 min answer windowingretractionssemantics