handle early events more cleaning in es.sink()
 early events are now discarded without causing deadlock!