Continuous query language (CQL) debugger in complex event processing (CEP)

Patent metadata

Field	Value
Publication number	US-9329975-B2
Application number	US-201113177748-A
Country	US
Kind code	B2
Filing date	Jul 7, 2011
Priority date	Jul 7, 2011
Publication date	May 3, 2016
Grant date	May 3, 2016

Abstract

A method including receiving, at a computer system, debugging configuration information specifying a functional area of a data stream processing server to be debugged, is described. Furthermore, the method includes identifying, by the computer system, an object associated with the functional area that has been instantiated by the data stream processing server, determining, by the computer system, that tracing for the object is enabled to perform the debugging, and instantiating, by the computer system, a tracelet associated with the object. Further, the method includes stepping, by the computer system, through the tracelet associated with the object to debug the object, and displaying, by the computer system, a visual representation of debugging results associated with the object.

First claim

What is claimed is:

1. A method comprising:
receiving, at a computer system, debugging configuration information specifying a functional area of a data stream processing server to be debugged, the functional area corresponding to at least one query plan object in a query plan associated with a continuous query;
identifying, by the computer system, the at least one query plan object in the query plan associated with the functional area that has been instantiated by the data stream processing server;
identifying, by the computer system, from the debugging configuration information, a first parameter identifying one or more events that cause debugging of the at least one query plan object, a second parameter identifying a level of detail for debugging the at least one query plan object, and a third parameter specifying a type of the at least one query plan object to be debugged, the level of detail determined based at least in part on the type of the at least one query plan object to be debugged;
determining, by the computer system, that tracing for the at least one query plan object is enabled to perform debugging of the at least one query plan object based at least in part on the first parameter, the second parameter and the third parameter, the first parameter, the second parameter and the third parameter being different from each other;
instantiating, by the computer system, a tracelet associated with the at least one query plan object, the tracelet including a segment of code for debugging the at least one query plan object;
stepping, by the computer system, through the tracelet associated with the at least one query plan object to debug the at least one query plan object; and
displaying, by the computer system, a visual representation of debugging results associated with the at least one query plan object.

2. The method of claim 1 , wherein enabling tracing for the at least one query plan object comprises:
storing the debugging configuration information for the at least one query plan object; and
generating one or more debugging records for the at least one query plan object based on the debugging configuration information stored for the at least one query plan object.

3. The method of claim 2 , further comprising disabling tracing for the at least one query plan object, wherein disabling tracing for the at least one query plan object comprises deleting the debugging configuration information stored for the at least one query plan object.

4. The method of claim 1 , further comprising determining that one or more breakpoints are set within the at least one query plan object.

5. The method of claim 4 , further comprising continuing through each of the one or more breakpoints to debug the at least one query plan object.

6. The method of claim 1 , further comprising in response to determining that tracing for the at least one query plan object is enabled, setting a tracing processing level.

7. The method of claim 1 , wherein the stepping further comprises:
stepping over operators in the at least one query plan object;
stepping into data structures of the operators; and
inspecting and watching the data structures of the operators.

8. The method of claim 6 , wherein the at least one query plan object includes an operator object and one or more data structure objects associated with the operator object.

9. The method of claim 8 , wherein if tracing is enabled for the operator object, tracing is automatically enabled for the one or more data structure objects associated with the operator object.

10. The method of claim 1 , further comprising:
identifying another query plan object associated with the functional area, wherein the another query plan object was instantiated by the data stream processing server subsequently to receiving logging configuration information; and
enabling logging for the another query plan object.

11. The method of claim 1 , wherein the debugging configuration information is received from a user and is expressed as breakpoint statements.

12. The method of claim 1 , wherein the debugging configuration information is received via an invocation of a Java Management Extensions (JMX) Applications Programming Interface (API).

13. A non-transitory machine-readable storage medium having sets of instructions stored thereon which when executed by a machine, cause the machine to:
receive debugging configuration information specifying a functional area of a data stream processing server to be debugged, the functional area corresponding to at least one query plan object in a query plan associated with a continuous query;
identify the at least one query plan object in the query plan associated with the functional area that has been instantiated by the data stream processing server;
identify, from the debugging configuration information, a first parameter identifying one or more events that cause debugging of the at least one query plan object, a second parameter identifying a level of detail for debugging the at least one query plan object, and a third parameter specifying a type of the at least one query plan object to be debugged, the level of detail determined based at least in part on the type of the at least one query plan object to be debugged;
determine that tracing for the at least one query plan object is enabled to perform debugging of the at least one query plan object based at least in part on the first parameter, the second parameter and the third parameter, the first parameter, the second parameter and the third parameter being different from each other;
instantiate a tracelet associated with the at least one query plan object, the tracelet including a segment of code for debugging the at least one query plan object;
step through the tracelet associated with the at least one query plan object to debug the at least one query plan object; and
display a visual representation of debugging results associated with the at least one query plan object.

14. The non-transitory machine-readable storage medium of claim 13 , wherein the sets of instructions further cause the machine to enable tracing for the at least one query plan object to further cause the machine to:
store the debugging configuration information for the at least one query plan object; and
generate one or more debugging records for the at least one query plan object based on the debugging configuration information stored for the at least one query plan object.

15. The non-transitory machine-readable storage medium of claim 13 , wherein the sets of instructions further cause the machine to enable tracing for the at least one query plan object further cause the machine to set one or more breakpoints within the at least one query plan object, wherein the one or more breakpoints are set within the continuous query and within data structures of the at least one query plan object.

16. The non-transitory machine-readable storage medium of claim 13 , wherein the sets of instructions further cause the machine to execute steps and breakpoints which cause a graphical representation of the at least one query plan object as the at least one query plan object is being debugged.

17. The non-transitory machine-readable storage medium of claim 13 , wherein the sets of instructions further cause the machine to invoke debugging of the at least one query plan object within a production platform.

18. A system comprising:
a memory device having sets of instructions stored thereon; and
a computer processor in communication with the memory device, wherein the computer processor exe

Assignees

• Park Hoyong
• Hsiao Eric
• Piper Andy
• Oracle Int Corp

Inventors

• Park Hoyong
• Hsiao Eric
• Piper Andy

Classifications

• G06F11/323

  Visualisation of programs or trace data · CPC title

• G06F8/20

  Software design · CPC title

• G06F11/3636 Primary

  by tracing the execution of the program · CPC title