Daniel E Musgrave

age ~41

from San Jose, CA

Get Report

Also known as:

Connected to:

Daniel Musgrave Phones & Addresses

Mitigating Slow Instances In Large-Scale Streaming Pipelines
view source
US Patent:

20220405186, Dec 22, 2022
Filed:

Aug 25, 2022
Appl. No.:

17/822212
Inventors:

- Redmond WA, US
Avrilia FLORATOU - Mountain View CA, US
Ke WANG - Pittsburgh PA, US
Daniel E. MUSGRAVE - San Jose CA, US
International Classification:

G06F 11/34
G06F 9/50
H04L 69/00
Abstract:

A system is described herein for mitigating slow process instances in a streaming application. The system includes a slow process instance candidate identifier configured to identify, based on a relative watermark latency, a set of slow process instance candidates from among a plurality of process instances that comprise the streaming application. The system further includes a set of filters configured to remove false positives from the set of slow process instance candidates. The filters account for window operations performed by the process instances as well as stabilization time needed for downstream process instances to stabilize after a slow upstream process instance is mitigated by a mitigation implementer, which may also be included in the system.

Mitigating Slow Instances In Large-Scale Streaming Pipelines
view source
US Patent:

20210133075, May 6, 2021
Filed:

Oct 31, 2019
Appl. No.:

16/670287
Inventors:

- Redmond WA, US
Avrilia Floratou - Mountain View CA, US
Ke Wang - Pittsburgh PA, US
Daniel E. Musgrave - San Jose CA, US
International Classification:

G06F 11/34
Abstract:

A system is described herein for mitigating slow process instances in a streaming application. The system includes a slow process instance candidate identifier configured to identify, based on a relative watermark latency, a set of slow process instance candidates from among a plurality of process instances that comprise the streaming application. The system further includes a set of filters configured to remove false positives from the set of slow process instance candidates. The filters account for window operations performed by the process instances as well as stabilization time needed for downstream process instances to stabilize after a slow upstream process instance is mitigated by a mitigation implementer, which may also be included in the system.