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:

  • TRACE
  • DEBUG
  • FATAL
  • ERROR
  • WARN
  • INFO

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     |