1.根据日志的种类分派线程的个数
2.只有新生成的日志才做map reduce统计
3.修改日志写入mongo报错
4.修改写入流关闭、异常捕获