Jihoon Son c48aa74a30 Fix NPE while handling CheckpointNotice in KafkaSupervisor (#5996) ... * Fix NPE while handling CheckpointNotice * fix code style * Fix test * fix test * add a log for creating a new taskGroup * fix backward compatibility in KafkaIOConfig		2018-07-13 17:14:57 -07:00
..
main	Fix NPE while handling CheckpointNotice in KafkaSupervisor (#5996)	2018-07-13 17:14:57 -07:00
test	Update license headers. (#5976)	2018-07-11 09:55:18 -07:00