APPLICATION BUNDLE PRELOADING

• US 20160342405A1
• Filed: 06/27/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,523,518 B2
• Time in Patent Office: Days
• US Class Current: 1/1
• CPC Class Codes: H04L 41/14 Network analysis or design
• CPC Class Codes: H04L 67/1095 Replication or mirroring of data, e.g. scheduling or transport for data synchronisation between network nodes
• CPC Class Codes: H04L 67/1097 for distributed storage of data in networks, e.g. transport arrangements for network file system [NFS], storage area networks [SAN] or network attached storage [NAS]
• CPC Class Codes: H04L 67/34 involving the movement of software or configuration parameters network booting or remote initial program loading [RIPL] G06F9/4416
• CPC Class Codes: H04L 67/52 specially adapted for the location of the user terminal

Abstract

Disclosed aspects include managing a set of application bundles for processing a stream of tuples. A set of application bundles which are installed on a second compute node is monitored by a first compute node. A candidate application bundle of the set of application bundles is detected by the first compute node. A determination is made to install the candidate application bundle on the first compute node. The determination is made by the first compute node based on a set of anticipation criteria. The candidate application bundle is installed on the first compute node.

Claims

1. A system for managing a set of application bundles for processing a stream of tuples, the system comprising:

a memory having a set of computer readable computer instructions, and

a processor for executing the set of computer readable instructions, the set of computer readable instructions including;

monitoring, by a first compute node, a set of application bundles which are installed on a second compute node;

detecting, by the first compute node, the set of application bundles includes a candidate application bundle;

determining, by the first compute node based on a set of anticipation criteria, to install the candidate application bundle on the first compute node; and

installing the candidate application bundle on the first compute node.

2. The system of claim 1, further comprising:

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

processing, using the candidate application bundle on the first compute node, the stream of tuples in response to installing the candidate application bundle on the first compute node.

3. The system of claim 1, wherein determining, by the first compute node based on the set of anticipation criteria, to install the candidate application bundle on the first compute node includes:

analyzing the set of anticipation criteria; and

identifying a criterion which indicates to install the candidate application bundle on the first compute node.

4. The system of claim 1, wherein the set of anticipation criteria includes:

an expected candidacy criterion of the first compute node for processing the stream of tuples.

5. The system of claim 1, wherein the set of anticipation criteria includes:

an expected resource burden criterion when processing the stream of tuples.

6. The system of claim 1, wherein the set of anticipation criteria includes:

an expected resource burden criterion when downloading the application bundle to the first compute node from the second compute node.

7. The system of claim 1, wherein the set of anticipation criteria includes:

a physical proximity criterion of the second compute node with respect to the first compute node.

8. The system of claim 1, wherein the set of anticipation criteria includes:

a failover frequency criterion of the second compute node.

9. The system of claim 1, wherein the set of anticipation criteria includes:

a temporal benefit criterion for processing the stream of tuples within a threshold temporal period.

10. The system of claim 1, wherein monitoring, by the first compute node, the set of application bundles which are installed on the second compute node includes:

observing the set of application bundles; and

analyzing the set of application bundles.

11. A computer program product for managing a set of application bundles for processing a stream of tuples, the computer program product comprising a computer readable storage medium having program instructions embodied therewith, wherein the computer readable storage medium is not a transitory signal per se, the program instructions executable by a processor to cause the processor to perform a method comprising:

monitoring, by a first compute node, a set of application bundles which are installed on a second compute node;

detecting, by the first compute node, the set of application bundles includes a candidate application bundle;

determining, by the first compute node based on a set of anticipation criteria, to install the candidate application bundle on the first compute node; and

installing the candidate application bundle on the first compute node.

12. The computer program product of claim 11, wherein the program instructions are stored in a computer readable storage medium in a data processing system, and wherein the program instructions were downloaded over a network from a remote data processing system.

13. The computer program product of claim 11, wherein the program instructions are stored in a computer readable storage medium in a server data processing system, and wherein the program instructions are downloaded over a network to a remote data processing system for use in a computer readable storage medium with the remote data processing system.