StreamingStragglerInfo(mapping=None, *, ignore_unknown_fields=False, **kwargs)Information useful for streaming straggler identification and debugging.
Attributes |
|
|---|---|
| Name | Description |
start_time |
google.protobuf.timestamp_pb2.Timestamp
Start time of this straggler. |
end_time |
google.protobuf.timestamp_pb2.Timestamp
End time of this straggler. |
worker_name |
str
Name of the worker where the straggler was detected. |
data_watermark_lag |
google.protobuf.duration_pb2.Duration
The event-time watermark lag at the time of the straggler detection. |
system_watermark_lag |
google.protobuf.duration_pb2.Duration
The system watermark lag at the time of the straggler detection. |