Patent ID: 9471431
Filing Date: 2016-10-18
CPC Classification: G06F,H04L

Claim Text:
1. A computer-implemented method executed by at least one processor for managing a streaming application, the method comprising: executing a streaming application that comprises a primary flow graph that includes a plurality of operators that process a plurality of data tuples, wherein the primary flow graph comprises a first portion for which data loss needs to be prevented; cloning the first portion of the primary flow graph to a virtual machine, wherein the cloned first portion comprises a buffer that stores data tuples for the cloned first portion; detecting when the first portion of the primary flow graph has a failure; notifying the cloned first portion of the failure; and in response to the notification of the failure, the cloned first portion outputs data tuples to the primary flow graph to avoid data loss by the first portion of the primary flow graph that had the failure.