The patent badge is an abbreviated version of the USPTO patent document. The patent badge does contain a link to the full patent document.

The patent badge is an abbreviated version of the USPTO patent document. The patent badge covers the following: Patent number, Date patent was issued, Date patent was filed, Title of the patent, Applicant, Inventor, Assignee, Attorney firm, Primary examiner, Assistant examiner, CPCs, and Abstract. The patent badge does contain a link to the full patent document (in Adobe Acrobat format, aka pdf). To download or print any patent click here.

Date of Patent:
May. 16, 2017

Filed:

Jun. 26, 2013
Applicant:

Datatorrent, Inc., Santa Clara, CA (US);

Inventors:

Amol J. Kekre, Fremont, CA (US);

Phu D. Hoang, Portola Valley, CA (US);

Chetan Narsude, Sunnyvale, CA (US);

Thomas Weise, Mountain View, CA (US);

Assignee:

DataTorrent, Inc., Santa Clara, CA (US);

Attorney:
Primary Examiner:
Int. Cl.
CPC ...
G06F 15/16 (2006.01); H04L 29/06 (2006.01); G06F 11/00 (2006.01); G06F 17/30 (2006.01);
U.S. Cl.
CPC ...
H04L 65/605 (2013.01); G06F 11/00 (2013.01); G06F 17/30516 (2013.01);
Abstract

Software for a distributed streaming platform monitors a first operator instance in a container for an application running on a distributed streaming platform over a networked cluster of servers. The first operator instance includes an input port that receives streaming windows from an upstream instance and an output port that emits streaming windows to a downstream instance. And the monitoring includes determining a window identifier for a streaming window which the first operator instance is processing. The software reports results of the monitoring to a master and receives a dynamic adjustment from the master. The dynamic adjustment includes launching a second operator instance of the same operator in the container. The software resumes a flow of streaming windows into the input port and the output port according to first recovery policy for the first operator instance and a second recovery policy for the second operator instance.


Find Patent Forward Citations

Loading…