stream_events
This table logs microbatches and other important events from the scheduler in an internal log table.
This table logs microbatches and other important events from the scheduler in an internal log table.
This table was renamed from kafka_config.kafka_events.
Column | Data Type | Description |
---|---|---|
event_time | TIMESTAMP | The time the event was logged. |
log_level | VARCHAR |
The type of event that was logged. Valid Values:
Default: INFO |
frame_start | TIMESTAMP | The time when the frame executed. |
frame_end | TIMESTAMP | The time when the frame completed. |
microbatch | INTEGER | The identification number of the associated microbatch. |
message | VARCHAR | A description of the event. |
exception | VARCHAR | If this log is in the form of a stack trace, this column lists the exception. |
Examples
This example shows typical rows from the stream_events table.
=> SELECT * FROM stream_config.stream_events;
-[ RECORD 1 ]-+-------------
event_time | 2016-07-17 13:28:35.548-04
log_level | INFO
frame_start |
frame_end |
microbatch |
message | New leader registered for schema stream_config. New ID: 0, new Host: 10.20.30.40
exception |
-[ RECORD 2 ]-+-------------
event_time | 2016-07-17 13:28:45.643-04
log_level | INFO
frame_start | 2015-07-17 12:28:45.633
frame_end | 2015-07-17 13:28:50.701-04
microbatch |
message | Generated tuples: test3|2|-2,test3|1|-2,test3|0|-2
exception |
-[ RECORD 3 ]-+----------------
event_time | 2016-07-17 14:28:50.701-04
log_level | INFO
frame_start | 2016-07-17 13:28:45.633
frame_end | 2016-07-17 14:28:50.701-04
microbatch |
message | Total rows inserted: 0
exception |