BREAKPOINT CONTINUATION FOR STREAM COMPUTING

• US 20150007143A1
• Filed: 06/28/2013
• Published: 01/01/2015
• Est. Priority Date: 06/28/2013
• Status: Active Grant

• Current Assignee: International Business Machines Corporation
• Original Assignee: International Business Machines Corporation
• Inventors: Barsness, Eric L., Branson, Michael J., Cobb, Bradford L., Santosuosso, John M.
• Granted Patent: US 9,372,780 B2
• Time in Patent Office: Days
• US Class Current: 717/129
• CPC Class Codes: G06F 11/3636 by tracing the execution of the program

Abstract

A first stream operator in a stream computing application receives and processes a first stream of tuples. The processing at the first stream operator is paused in response to receiving a first one of the tuples in the first stream that triggers a breakpoint in the first stream operator. A determination of whether a condition to release the breakpoint is met is made, and the breakpoint is released in response to determining that the condition is met. The condition to release the breakpoint may be that a count of tuples of the first stream is outside of a threshold. A second stream of tuples may be received for processing at a second stream operator. The condition to release the breakpoint may be that a count of tuples of the second stream is outside of a threshold.

Claims

1. A method for debugging a stream computing application having a plurality of processing elements operating on one or more computer processors, each processing element having one or more stream operators, comprising:

receiving a first stream of tuples at a first stream operator;

processing the first stream of tuples at the first stream operator;

pausing the processing at the first stream operator in response to receiving a first one of the tuples in the first stream that triggers a breakpoint in the first stream operator;

determining whether a condition to release the breakpoint is met; and

releasing the breakpoint in response to determining that the condition is met.

2. The method of claim 1, wherein the condition to release the breakpoint is that a count of tuples of the first stream is outside of a threshold.

3. The method of claim 1, further comprising receiving a second stream of tuples to be processed at a second stream operator, wherein the condition to release the breakpoint is that a count of tuples of the second stream is outside of a threshold.

4. The method of claim 1, further comprising receiving a second stream of tuples to be processed at a second stream operator and a third stream of tuples to be processed at a third stream operator, wherein the condition to release the breakpoint is that one of first and second counts of tuples of the second and third streams is outside of respective first and second thresholds.

5. The method of claim 1, wherein the condition to release the breakpoint is that a quantity of tuples of the first stream per unit of time is outside of a threshold.

6. The method of claim 1, further comprising receiving a second stream of tuples to be processed at a second stream operator, wherein the condition to release the breakpoint is that a quantity of tuples of the second stream per unit of time is outside of a threshold.

7. The method of claim 1, further comprising determining whether a first attribute of the tuple meets an attribute condition, wherein the condition to release the breakpoint is that a count of tuples of the first stream that meet the attribute condition is outside of a threshold.

8. The method of claim 1, wherein the condition to release the breakpoint is that a first quantity of tuples of the first stream per unit of time changes to a second quantity of tuples of the first stream per unit of time, and a difference between the first quantity of tuples of the first stream per unit of time and the second quantity of tuples of the first stream per unit of time is outside of a threshold.

9. A computer program product for processing a stream of tuples, the computer program product comprising a computer readable storage medium having program code embodied therewith, the program code comprising computer readable program code configured to facilitate debugging of a stream computing application having a plurality of processing elements operating on one or more computer processors, each processing element having one or more stream operators, comprising:

receiving a first stream of tuples at a first stream operator;

processing the first stream of tuples at the first stream operator;

pausing the processing at the first stream operator in response to receiving a first one of the tuples in the first stream that triggers a breakpoint in the first stream operator;

determining whether a condition to release the breakpoint is met; and

releasing the breakpoint in response to determining that the condition is met.

10. The computer program product of claim 9, wherein the condition to release the breakpoint is that a count of tuples of the first stream is outside of a threshold.

11. The computer program product of claim 9, further comprising receiving a second stream of tuples to be processed at a second stream operator, wherein the condition to release the breakpoint is that a count of tuples of the second stream is outside of a threshold.

12. The computer program product of claim 9, further comprising receiving a second stream of tuples to be processed at a second stream operator and a third stream of tuples to be processed at a third stream operator, wherein the condition to release the breakpoint is that one of first and second counts of tuples of the second and third streams is outside of respective first and second thresholds.

13. The computer program product of claim 9, wherein the condition to release the breakpoint is that a quantity of tuples of the first stream per unit of time is outside of a threshold.

14. The computer program product of claim 9, further comprising receiving a second stream of tuples to be processed at a second stream operator, wherein the condition to release the breakpoint is that a quantity of tuples of the second stream per unit of time is outside of a threshold.

15. The computer program product of claim 9, further comprising determining whether a first attribute of the tuple meets an attribute condition, wherein the condition to release the breakpoint is that a count of tuples of the first stream that meet the attribute condition is outside of a threshold.

16. The computer program product of claim 9, wherein the condition to release the breakpoint is that a first quantity of tuples of the first stream per unit of time changes to a second quantity of tuples of the first stream per unit of time, and a difference between the first quantity of tuples of the first stream per unit of time and the second quantity of tuples of the first stream per unit of time is outside of a threshold.

17-20. -20. (canceled)