我有spark单节点，我打算用apacheflume->spark->mysql将数据流到mysql中，我使用foreachpartition方法，但是数据插入变慢了，spark ui中有一个队列。
有什么建议可以改进这个数据插入。我需要每秒处理3000行。