stream_events
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 value: 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.100.62 004:9092,eng-g9-005:9092), resource pool: kafka_default_pool 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 |