Managing stream components based on virtual machine performance adjustments

摘要

Embodiments of the disclosure include a method, a system, and a computer program product for modifying a stream operator based on the virtual resources. The method includes receiving a first resource allocation and a second resource allocation of a virtual resource for a virtual machine supporting a stream computing application. The method also includes determining whether the second resource allocation changed within a tolerance relative to the first resource allocation. The method also includes identifying a stream operator in the stream computing application using the virtual resource of the virtual machine. The method also includes modifying the stream operator to accommodate the second resource allocation in response to the second resource allocation changing relative to the first resource allocation.

主权项

1. A system comprising:
a virtual machine stored in a memory hosting at least one processing element, the processing element containing a plurality of stream operators from a stream computing application; one or more servers providing a plurality of virtual resources to the virtual machine; a stream application that manages allocation of the plurality of virtual resources from the one or more servers to the virtual machine, the stream application configured to:
initialize, based on a processing element, a first resource allocation of a first virtual resource,monitor operation of the virtual machine to allocate one or more virtual resources including the first virtual resource,detecting, based on the monitored operation of the virtual machine, a second resource allocation,determining, based on the detected second resource allocation, an increase in the first virtual resource compared to the first resource allocation,identify, based on the detected second resource allocation, the processing element of the stream application,increasing, based on the determined increase in the virtual resource and based on the identified processing element, a first stream operator function of the processing element of the plurality of stream operators, the first stream operator function corresponding to the first virtual resource;determine a resource dependency that the first stream operator function depends on a second stream operator function corresponding to a second virtual resource, wherein the resource dependency is a ratio between the first stream operator function and the second stream operator function and is based on tuple processing performance monitored by the stream application, andincrease, based on the determined resource dependency, the stream operator function of the processing element.