MANAGING STALENESS LATENCY AMONG APPLICATION BUNDLES

• US 20160342659A1
• Filed: 05/21/2015
• Published: 11/24/2016
• Est. Priority Date: 05/21/2015
• Status: Active Grant

• Current Assignee: International Business Machines Corporation
• Original Assignee: International Business Machines Corporation
• Inventors: Fawcett, Bradley W.
• Granted Patent: US 10,152,516 B2
• Time in Patent Office: Days
• US Class Current: 1/1
• CPC Class Codes: G06F 16/24568 Data stream processing; Continuous queries
• CPC Class Codes: G06F 16/24578 using ranking
• CPC Class Codes: G06F 9/46 Multiprogramming arrangements
• CPC Class Codes: G06F 9/5011 the resources being hardware resources other than CPUs, Servers and Terminals
• CPC Class Codes: H04L 65/75 Media network packet handling
• CPC Class Codes: H04L 67/10 in which an application is distributed across nodes in the network software deployment G06F8/60; multiprogramming arrangements G06F9/46
• CPC Class Codes: H04L 67/34 involving the movement of software or configuration parameters network booting or remote initial program loading [RIPL] G06F9/4416

Abstract

Disclosed aspects include managing an application bundle for processing a stream of tuples. The stream of tuples to be processed by a plurality of processing elements operating on a set of compute nodes is received. The stream of tuples is processed on a first compute node using the application bundle. A staleness factor with respect to the application bundle is detected by the first compute node. Based on a maintenance criterion related to both the application bundle and the plurality of processing elements, the application bundle is maintained on the first compute node.

Claims

1. A computer-implemented method for managing an application bundle for processing a stream of tuples, the method comprising:

receiving the stream of tuples to be processed by a plurality of processing elements operating on a set of compute nodes;

processing, on a first compute node using the application bundle, the stream of tuples;

detecting, by the first compute node, a staleness factor with respect to the application bundle; and

maintaining, based on a maintenance criterion related to both the application bundle and the plurality of processing elements, the application bundle on the first compute node.

2. The method of claim 1, wherein maintaining the application bundle includes:

preserving the application bundle on the first compute node; and

preventing removal of the application bundle from the first compute node.

3. The method of claim 1, wherein the maintenance criterion includes a threshold temporal value.

4. The method of claim 1, wherein the maintenance criterion includes a threshold computing resources value.

5. The method of claim 1, wherein the maintenance criterion includes a threshold processing element accessibility value.

6. The method of claim 1, wherein using the application bundle when activating the plurality of processing elements.

7. The method of claim 1, wherein the staleness factor with respect to the application bundle interrelates with the plurality of processing elements.

8. The method of claim 1, wherein detecting, by the first compute node, the staleness factor with respect to the application bundle includes:

comparing, with a threshold value, an activity value of the application bundle; and

determining the activity value is below the threshold value.

9-20. -20. (canceled)