executors

0зной

2ответ

У меня есть вопрос, связанный с функцией Storm. Предположим, у меня есть носик, который читает csv-файл и испускает фрагмент записей куском. То есть, он испускает 100 записей за раз на болт. Мой вопро

4зной

1ответ

Spark: Executor Lost Failure (После добавления задания GroupBy)

Я пытаюсь запустить Spark работу с клиентом Yarn. У меня есть два узла, и каждый узел имеет следующие конфигурации. Я получаю «ExecutorLostFailure (исполнитель 1 потерян)». Я пробовал большую часть ко

1зной

1ответ

Установите доступные процессоры в Executors.newFixedThreadPool в HTTPServer

Я создаю HTTPServer, который должен обрабатывать несколько запросов одновременно. Основная функция того, что я построил, выглядит так: public static void main(String[] args) throws Exception { Ht

1зной

2ответ

Как получить доступ к объектам потока внутри пользовательских методов исполнителей потока?

Я хочу получить доступ к данным внутри исполняемых объектов, которые у меня есть в пользовательском исполнителе threadpool. Если я попытался получить доступ к методам before/after execute, я получаю и

1зной

1ответ

Что является наиболее рекомендуемым способом с помощью таймера в Java

Я работаю над программированием сокетов в java.I должны использовать таймер в каждом соединении, и я использую таймер как следующий код: this.timeoutTask = new TimeoutTask(); this.timeoutTimer = Exec