Log visualization tool for a data stream processing server

• US 8,386,466 B2
• Filed: 08/03/2009
• Issued: 02/26/2013
• Est. Priority Date: 08/03/2009
• Status: Active Grant

• Current Assignee: Oracle International Corporation (Oracle Corporation)
• Original Assignee: Oracle International Corporation (Oracle Corporation)
• Inventors: Park, Hoyong, Komuravelli, Rakesh, Jain, Namit, Srinivasan, Anand, Mishra, Shailendra
• Primary Examiner(s): NGUYEN, MERILYN P
• Application Number:
  US12/534,398
• Publication Number:
  US 20110029485A1
• Time in Patent Office: 1,303 Days
• Field of Search: 707/713, 707/718, 707/758, 707/762, 707/767, 707/768, 707/779, 707/798
• US Class Current: 707/713
• CPC Class Codes: G06F 16/2358 Change logging, detection, and notification replication G06F16/27

Abstract

Techniques for logging data pertaining to the operation of a data stream processing server. In one set of embodiments, logging configuration information can be received specifying a functional area of a data stream processing server to be logged. Based on the logging configuration information, logging can be dynamically enabled for objects associated with the functional area that are instantiated by the data stream processing server, and logging can be dynamically disabled for objects associated with the functional area that are discarded (or no longer used) by the data stream processing server. In another set of embodiments, a tool can be provided for visualizing the data logged by the data stream processing server.

Claims

1. A method comprising:

receiving, at a computer system, a file comprising log records generated by a data stream processing server, the log records including information pertaining to a query plan and a sequence of events executed by the data stream processing server in accordance with the query plan;

generating, by the computer system, a graphical representation of the query plan based on the log records;

displaying, by the computer system, the graphical representation;

wherein the graphical representation depicts one or more queue objects; and

as the computer system processes queue-based events reflected in the log records, the computer system modifies the graphical representation to indicate, for each particular queue object of the one or more queue objects, a current state of the particular queue object.

2. The method of claim 1 wherein the graphical representation comprises one or more nodes, each node representing a query plan object in the query plan.

3. The method of claim 2 further comprising:

in response to a user input, displaying state information for a node.

4. The method of claim 1 further comprising:

in response to a first user input, visually portraying the execution of the one or more events in sequence by animating the graphical representation.

5. The method of claim 4 wherein visually portraying the execution of the one or more events in sequence comprises visually portraying the execution of the one or more events in real-time based on timestamps associated with the one or more events.

6. The method of claim 4 further comprising:

in response to a second user input, pausing the animation.

7. The method of claim 4 further comprising, if the log records indicate that an error occurred during execution of an event in the one or more events, displaying a representation of the error in the graphical representation.

8. The method of claim 4 further comprising:

providing the one or more events as one or more data streams to another data stream processing server;

receiving a continuous query to be executed against the one or more data streams; and

causing the continuous query to be executed by the another data stream processing server while the graphical representation is being animated.

9. The method of claim 8 further comprising:

if a result for the continuous query is received from the another data stream processing server, pausing the animation.

10. The method of claim 8 further comprising:

if a result for the continuous query is received from the another data stream processing server, displaying an alert.

11. A machine-readable non-transitory storage medium having stored thereon program code executable by a computer system, the program code comprising:

code that causes the computer system to receive a file comprising log records generated by a data stream processing server, the log records including information pertaining to a query plan and a sequence of events executed by the data stream processing server in accordance with the query plan;

code that causes the computer system to generate a graphical representation of the query plan based on the log records;

code that causes the computer system to display the graphical representation;

wherein the graphical representation depicts one or more queue objects; and

code which, as the computer system processes queue-based events reflected in the log records, causes the computer system to modify the graphical representation to indicate, for each particular queue object of the one or more queue objects, a current state of the particular queue object.

12. The machine-readable non-transitory storage medium of claim 11 wherein the program code further comprises:

code that causes the computer system to, in response to a first user input, visually portray the execution of the one or more events in sequence by animating the graphical representation.

13. The machine-readable non-transitory storage medium of claim 12 wherein the program code further comprises:

code that causes the computer system to provide the one or more events as one or more data streams to another data stream processing server;

code that causes the computer system to receive a continuous query to be executed against the one or more data streams; and

code that causes the computer system to cause the continuous query to be executed by the another data stream processing server while the graphical representation is being animated.

14. A system comprising:

a storage component configured to store a file comprising log records generated by a data stream processing server, the log records including information pertaining to a query plan and a sequence of events executed by the data stream processing server in accordance with the query plan; and

a processing component in communication with the storage component, the processing component being configured to;

generate a graphical representation of the query plan based on the log records;

display the graphical representation;

wherein the graphical representation depicts one or more queue objects; and

as the processing component processes queue-based events reflected in the log records, modify the graphical representation to indicate, for each particular queue object of the one or more queue objects, a current state of the particular queue object.

15. The system of claim 14 wherein the processing component is further configured to, in response to a first user input, visually portray the execution of the one or more events in sequence by animating the graphical representation.

16. The system of claim 15 wherein the processing component is further configured to:

provide the one or more events as one or more data streams to another data stream processing server;

receive a continuous query to be executed against the one or more data streams; and

cause the continuous query to be executed by the another data stream processing server while the graphical representation is being animated.