Java spark创建线程2万多个，无法回收，
导致服务器所有的java程序 都无法创建新的线程而停止
代码
运行结果及报错内容
初步发现 JavaDStream foreachRDD时 是正常的 主要问题应该是
JavaInputDStream 在flatMap创建的线程没有回收 通过日志打印
在flatMap方法里面 创建的线程名称 Executor task launch worker for task 数在不断增加没有回收
我想要达到的结果
解决 JavaInputDStream 在flatMap创建的线程没有回收 问题
线程池大家都懂， 关键是怎么控制 JavaInputDStream 在flatMap的线程池
