USING CLOUD RESOURCES TO IMPROVE PERFORMANCE OF A STREAMING APPLICATION

• US 20150127777A1
• Filed: 04/16/2014
• Published: 05/07/2015
• Est. Priority Date: 11/07/2013
• Status: Active Grant

• Current Assignee: AirBNB Incorporated
• Original Assignee: International Business Machines Corporation
• Inventors: Branson, Michael J., Cao, Bin, Carey, James E., Bragstad, Lance, Odden, Mathew R.
• Granted Patent: US 9,628,353 B2
• Time in Patent Office: Days
• US Class Current: 709/219
• CPC Class Codes: H04L 41/5009 Determining service level performance parameters or violations of service level contracts, e.g. violations of agreed response time or mean time between failures [MTBF]
• CPC Class Codes: H04L 41/5096 wherein the managed service relates to distributed or central networked applications
• CPC Class Codes: H04L 43/04 Processing captured monitoring data, e.g. for logfile generation
• CPC Class Codes: H04L 65/752 adapting media to network capabilities
• CPC Class Codes: H04L 65/80 Responding to QoS

Abstract

A streams manager monitors performance of a streaming application, and when the performance needs to be improved, the streams manager automatically requests virtual machines from a cloud manager. The streams manager specifies to the cloud manager streams infrastructure and one or more streams application components for the virtual machines. The cloud manager provisions one or more virtual machines in a cloud with the specified streams infrastructure and streams application components. The streams manager then modifies the flow graph so one or more portions of the streaming application are hosted by the virtual machines in the cloud.

Claims

1. An apparatus comprising:

at least one processor;

a memory coupled to the at least one processor;

a streaming application residing in the memory and executed by the at least one processor, the streaming application comprising a flow graph that includes a plurality of operators that process a plurality of data tuples; and

a streams manager residing in the memory and executed by the at least one processor, the streams manager monitoring performance of the streaming application, and when performance of the streaming application needs to be improved, the streams manager requests a cloud manager to provision at least one virtual machine with logic to implement at least one of the plurality of operators, and when the cloud manager provisions the at least one virtual machine, the streams manager modifies the flow graph to include the at least one virtual machine in the flow graph of the streaming application.

2. The apparatus of claim 1 wherein the streams manager monitors the performance of the streaming application by comparing current performance of the streaming application to at least one defined performance threshold.

3. The apparatus of claim 2 wherein the streams manager, by comparing the performance of the streaming application to the at least one defined threshold, determines when the performance of the streaming application needs to be improved.

4. The apparatus of claim 1 wherein the logic to implement the at least one of the plurality of operators comprises:

software that provides a streaming infrastructure; and

software running in the streaming infrastructure that implements the at least one of the plurality of operators.

5. The apparatus of claim 1 wherein the request from the streams manager to the cloud manager to provision at least one virtual machine comprises a request that specifies:

a number of virtual machines to provision;

a specified streams infrastructure to provision; and

at least one specified component of the streams application.

6. The apparatus of claim 5 wherein the request specifies for each of the number of virtual machines to provision:

the specified streams infrastructure; and

the at least one specified component of the streams application to provision in the virtual machine.

7. The apparatus of claim 1 wherein the at least one virtual machine implements logic for a selected one of the plurality of operators, wherein the at least one virtual machine processes tuples in parallel with the selected one operator in the flow graph after the streams manager modifies the flow graph of the streaming application.

8. The apparatus of claim 7 wherein the streams manager modifies the flow graph to include a new operator that splits tuples from an existing operator to the selected one operator in the flow graph and to the at least one virtual machine that processes the tuples in parallel with the selected one operator in the flow graph.