fix es.sink thread safety issue