Application bundle management in stream computing
First Claim
Patent Images
1. A system for managing a plurality of application bundles for processing a stream of tuples, the system comprising:
- a memory having a set of computer readable computer instructions, anda processor for executing the set of computer readable instructions, the set of computer readable instructions including;
receiving the stream of tuples to be processed by a plurality of processing elements operating on a set of compute nodes;
executing, on a first compute node using the plurality of application bundles, the stream of tuples;
monitoring, by an application bundle monitor, which application bundle is executing the stream of tuples, wherein the application bundle monitor controls a policy setting for the first compute node, wherein the policy setting is selected from the group consisting of a computing resource, a job status, a processing element status and a configuration;
detecting, by the application bundle monitor, a first application bundle is executing the monitored stream of tuples;
detecting, by the application bundle monitor, a second application bundle is executing a second stream of tuples;
detecting, by the application bundle monitor, the monitored stream of tuples is finished being executed by the first application bundle;
determining, by the first compute node, a staleness factor of the first application bundle has exceeded a policy setting threshold value of the first compute node, wherein the staleness factor is determined by considering the policy setting of the first node and the activity value of the first application bundle;
removing, by the first compute node, the first application bundle; and
maintaining, by the first compute node, execution of the second stream of tuples by the second application bundle.
1 Assignment
0 Petitions
Accused Products
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.
-
Citations
11 Claims
-
1. A system for managing a plurality 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; receiving the stream of tuples to be processed by a plurality of processing elements operating on a set of compute nodes; executing, on a first compute node using the plurality of application bundles, the stream of tuples; monitoring, by an application bundle monitor, which application bundle is executing the stream of tuples, wherein the application bundle monitor controls a policy setting for the first compute node, wherein the policy setting is selected from the group consisting of a computing resource, a job status, a processing element status and a configuration; detecting, by the application bundle monitor, a first application bundle is executing the monitored stream of tuples; detecting, by the application bundle monitor, a second application bundle is executing a second stream of tuples; detecting, by the application bundle monitor, the monitored stream of tuples is finished being executed by the first application bundle; determining, by the first compute node, a staleness factor of the first application bundle has exceeded a policy setting threshold value of the first compute node, wherein the staleness factor is determined by considering the policy setting of the first node and the activity value of the first application bundle; removing, by the first compute node, the first application bundle; and maintaining, by the first compute node, execution of the second stream of tuples by the second application bundle. - View Dependent Claims (2, 3, 4, 5, 6, 7)
-
-
8. A computer program product for managing a plurality 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:
-
receiving the stream of tuples to be processed by a plurality of processing elements operating on a set of compute nodes; executing, on a first compute node using the plurality of application bundles, the stream of tuples; monitoring, by an application bundle monitor, which application bundle is executing the stream of tuples, wherein the application bundle monitor controls a policy setting for the first compute node, wherein the policy setting is selected from the group consisting of a computing resource, a job status, a processing element status and a configuration; detecting, by the application bundle monitor, a first application bundle is executing the monitored stream of tuples; detecting, by the application bundle monitor, a second application bundle is executing a second stream of tuples; detecting, by the application bundle monitor, the monitored stream of tuples is finished being executed by the first application bundle; determining, by the first compute node, a staleness factor of the first application bundle has exceeded a policy setting threshold value of the first compute node, wherein the staleness factor is determined by considering the policy setting of the first node and the activity value of the first application bundle; removing, by the first compute node, the first application bundle; and maintaining, by the first compute node, execution of the second stream of tuples by the second application bundle. - View Dependent Claims (9, 10, 11)
-
Specification