загрузка спарк-jms-приемника делает занятым только одного потребителя - PullRequest
2 голосов
/ 18 марта 2019

У меня есть специальный приемник JMS для свечей и данные, опубликованные третьей стороной. В настоящее время при этом я вижу только одного работающего потребителя, что приводит к тому, что один искровый исполнитель привыкает, из-за того, что через некоторое время я получаю ошибку GC overhead.

как сделать несколько потребителей так, чтобы данные могли обрабатываться несколькими исполнителями?

Я попытался переразбить после прочтения Dsreams, но производитель пишет немного быстрее, следовательно, через некоторое время больше записей собирается у одного потребителя, и это вызывает ошибку памяти GC.

...