Method onError

driver/mysql/extractor.go:1547–1559

(state int, err error)

}

func (e *Extractor) onError(state int, err error) {
	e.logger.Error("onError", "err", err, "hasShutdown", e.shutdown)
	if e.shutdown {
		return
	}
	common.WriteWaitCh(e.waitCh, &drivers.ExitResult{
		ExitCode:  state,
		Signal:    0,
		OOMKilled: false,
		Err:       err,
	})
	_ = e.Shutdown()
}
// Shutdown is used to tear down the extractor
func (e *Extractor) Shutdown() error {
	e.logger.Debug("extractor shutdown")