DTLE-kafka create job dead , the automated test failed

[yaqigithub]

Description
when create kafka job ,the job dead,

Steps to reproduce the issue:
1.
2.
3.

Describe the results you received:
the job dead

Describe the results you expected:

Output of ./dtle version:

Dtle 9.9.9.9 (git: master 50661109df5f605f60d18eba396c7ab6f2a44fa7)

Additional information you deem important (e.g. issue happens only occasionally):

Additional details (log, config, job config etc):
1、log

2019/06/11 19:17:27.200285 [DEBUG] [jobid:d5c0131b-64a6-1d9a-436b-8dc3cffedab6] mysql.extractor: publish. gtid: , msg_len: 898 
2019/06/11 19:17:27.200589 [DEBUG] [jobid:d5c0131b-64a6-1d9a-436b-8dc3cffedab6] kafka: recv a msg 
2019/06/11 19:17:27.200952 [DEBUG] setState 4 
2019/06/11 19:17:27.200975 [DEBUG] setState.SaveState 
2019/06/11 19:17:27.201020 [INFO] [jobid:d5c0131b-64a6-1d9a-436b-8dc3cffedab6] kafka: Shutting down 
2019/06/11 19:17:27.201110 [DEBUG] Worker.SaveState: lock: 0xc0001d5e30, 0xc000167c20 
2019/06/11 19:17:27.201122 [DEBUG] Worker.SaveState: after lock: 0xc0001d5e30 
2019/06/11 19:17:27.201133 [DEBUG] Worker.SaveState: after unlock: 0xc0001d5e30 
2019/06/11 19:17:27.201141 [DEBUG] updater 
2019/06/11 19:17:27.201166 [ERR] agent: Task "Dest" for alloc "bf66695f-9426-421e-dec0-98a7ddd03275" failed: Wait returned exit code 2, and error DTLE_BUG kafka: unk
nown table structure 
2019/06/11 19:17:27.201181 [INFO] agent: Not restarting task: Dest for alloc: bf66695f-9426-421e-dec0-98a7ddd03275  
2019/06/11 19:17:27.201190 [DEBUG] setState restart 1 
2019/06/11 19:17:27.201210 [DEBUG] setState.SaveState 
2019/06/11 19:17:27.201294 [DEBUG] Worker.SaveState: lock: 0xc0001d5e30, 0xc000167c20 
2019/06/11 19:17:27.201308 [DEBUG] Worker.SaveState: after lock: 0xc0001d5e30 
2019/06/11 19:17:27.201319 [DEBUG] Worker.SaveState: after unlock: 0xc0001d5e30 
2019/06/11 19:17:27.201329 [DEBUG] updater 
2019/06/11 19:17:27.201339 [DEBUG] setTaskState: dirtyCh<-