spark流处理时连接池造成锁死，请问怎么解锁？

在使用spark连接kafka处理数据流的过程中，不知道为啥会造成java.util.concurrent.threadPoolExecutor锁死，请问怎么释放这个锁呢？