Algorithmic changing in a streaming environment

Patent metadata

Field	Value
Publication number	US-2016248688-A1
Application number	US-201514625819-A
Country	US
Kind code	A1
Filing date	Feb 19, 2015
Priority date	Feb 19, 2015
Publication date	Aug 25, 2016
Grant date	—

Abstract

A stream computing application may permit one job to connect to a data stream of a different job. As more jobs dynamically connect to the data stream, the connections may have a negative impact on the performance of the stream computing application. A variety of performance indicators (e.g., CPU utilization or tuple rate) may be monitored to determine if the dynamic connections are harming performance. If they are, the stream algorithm may be modified to mitigate the effects of the dynamic connections.

First claim

1 - 16 . (canceled)

17 . A system for modifying a stream computing application comprising:
a plurality of processing elements to receive a stream of tuples, each processing element including one or more stream operators, wherein one or more of the stream operators include code configured to output tuples to one or more other stream operators; two or more processors; and a memory containing an application that, when executed, causes at least one of the two or more processors to:
establish a contract wherein the contract includes one or more algorithm changes;
determine whether there are one or more dynamic connections;
determine, in response to determining that there are one or more dynamic connections, whether a bottleneck condition is present; and
modify, in response to determining that the bottleneck condition is present, a stream algorithm using the algorithm changes.

18 . A computer program product comprising a computer readable storage media having a computer readable program stored therein, wherein the computer readable program, when executed on a computing device, causes the computing device to:
receive a stream of tuples to be processed by a plurality of processing elements, each processing element including one or more stream operators, wherein one or more of the stream operators include code configured to output tuples to one or more other stream operators; establish a contract wherein the contract includes one or more algorithm changes; determine whether there are one or more dynamic connections; determine, in response to determining that there are one or more dynamic connections, whether a bottleneck condition is present; and modify, in response to determining that the bottleneck condition is present, a stream algorithm using the algorithm changes.

Assignees

• IBM

Inventors

• Barsness Eric L
• Branson Michael J
• Santosuosso John M

Classifications

• H04L43/0894

  Packet rate · CPC title

• H04L47/25 Primary

  with rate being modified by the source upon detecting a change of network conditions · CPC title

• H04L49/9005

  using dynamic buffer space allocation · CPC title

• H04L65/604

  Electricity · mapped topic

• G06F16/24568 Primary

  Data stream processing; Continuous queries · CPC title