Как управлять ресурсами Spark-приложения, чтобы не перерасходовать память при изменении объёма входных данных?