{
  "allowed_lateness_3": {
    "aggregate_history": {
      "0": 2,
      "5": 1
    },
    "emitted": [
      [
        0,
        1,
        "on-time"
      ],
      [
        0,
        2,
        "late-update"
      ],
      [
        5,
        1,
        "on-time"
      ]
    ],
    "final_watermark": 10,
    "live_state": {
      "5": 1
    },
    "side_output": []
  },
  "arrival_order": [
    [
      "event",
      2,
      1
    ],
    [
      "event",
      8,
      1
    ],
    [
      "watermark",
      6,
      0
    ],
    [
      "event",
      4,
      1
    ],
    [
      "watermark",
      10,
      0
    ]
  ],
  "backpressure": {
    "accepted": 18,
    "backpressured_steps": 5,
    "consumed": 18,
    "dropped": 0,
    "max_source_pending": 9,
    "offered": 18
  },
  "checkpoint_recovery": {
    "checkpoint_offset": 1,
    "external_effect_count": 2,
    "external_sink": [
      "effect-for-event-8",
      "effect-for-event-8"
    ],
    "final_offset_after_replay": 2,
    "restored_offset": 1,
    "restored_state_after_replay": {
      "count": 2
    }
  },
  "conclusions": {
    "backpressure_retains_unadmitted_input_without_implying_drop": true,
    "checkpoint_restores_managed_state_not_external_effect": true,
    "expired_window_state_is_cleaned": true,
    "lateness_policy_changes_result": true,
    "watermark_closes_event_time_frontier": true
  },
  "model": "deterministic streaming-boundary model",
  "not_modeled": [
    "Flink runtime",
    "distributed barriers and asynchronous checkpoints",
    "transactional sink",
    "unbounded source retention, network, or performance"
  ],
  "zero_allowed_lateness": {
    "aggregate_history": {
      "0": 1,
      "5": 1
    },
    "emitted": [
      [
        0,
        1,
        "on-time"
      ],
      [
        5,
        1,
        "on-time"
      ]
    ],
    "final_watermark": 10,
    "live_state": {},
    "side_output": [
      [
        4,
        1,
        "too-late"
      ]
    ]
  }
}