FlumeConcurrent