Описание тега apache-storm
Storm - это распределенная система вычислений в реальном времени. Подобно тому, как Hadoop предоставляет набор общих примитивов для пакетной обработки, Storm предоставляет набор общих примитивов для выполнения вычислений в реальном времени. Storm прост, может использоваться с любым языком программирования
1
ответ
Может ли один и тот же экземпляр Zookeeper использоваться рядом служб?
Достаточно ли хороша одна установка Zookeeper для использования кластерами Hadoop Kafka и Storm? Я хочу развернуть все в одной тестовой среде и попробовать поиграть с этими технологиями. Могу ли я использовать для этого одну установку zookeeper? так…
21 июн '14 в 09:36
1
ответ
Как изменить начальные, последующие и запрещенные URL-адреса для StormCrawler на лету
Я довольно новичок в StormCrawler, делаю свою первую реализацию веб-сканера, и я до сих пор очень доволен этим продуктом! Я использую StormCrawler v1.5.1 с Elastic 5.5.1 и настраиваю свою топологию на основе предоставленного "ESCrawlTopology.java". …
08 авг '17 в 09:12
2
ответа
Как заставить Storm остановиться на исключение?
По умолчанию, когда носик или болт Storm встречает исключение, он перезапускает носик или болт и пытается снова. Есть ли какая-либо опция конфигурации, чтобы остановить топологию, возможно, после N повторных попыток? (Например, Hadoop пытается 4 раз…
26 мар '14 в 19:46
1
ответ
Исключение в KafkaSpout
Я получаю следующую исключительную топологию шторма. java.lang.NoSuchMethodError: org.apache.kafka.common.network.NetworkSend.<init>(Ljava/lang/String;[Ljava/nio/ByteBuffer;)V at kafka.network.RequestOrResponseSend.<init>(RequestOrRespon…
27 авг '18 в 09:43
1
ответ
Относительно проблемы с Multi-Lang в шторме при запуске Python (WordCountTopology)
Я пытаюсь запустить WordCountTopology в штормовом локальном режиме, прежде чем запускать собственное приложение, и я не могу его запустить. Я постоянно получаю следующую ошибку. Я подтвердил, что splitsentence.py файл хранится в multilang/resources …
06 авг '17 в 22:12
0
ответов
Генерация динамического файла правил (.drl) из базы данных с использованием шаблона правила
Мы сгенерировали файл правил из базы данных, используя шаблон правила, он работает, но мы сталкиваемся с одной проблемой: правила в правилах генерируются столько же, сколько записей в таблице. Так что в соответствии с моим требованием он не должен г…
21 ноя '16 в 11:30
0
ответов
Метод штормовой атаки
В настоящее время у меня есть простая топология. Он имеет носик для чтения данных, болт для преобразования данных и болт для хранения данных в хранилище данных. Я установил якоря, чтобы получить ответ на любой сбой кортежей. Из-за того, как я считыв…
25 июн '14 в 17:42
1
ответ
Запуск топологии Trident в модульном тесте с отслеживаемой топологией Storm
Как запустить тест JUnit для топологии Trident, чтобы позволить кортежам проходить через топологию во время тестирования и проверки выходных данных на каждом этапе? Я пытался запустить в рамках среды тестирования Storm, но он не дает возможности про…
14 май '15 в 18:42
0
ответов
Сериализованный класс не нашел исключения в Apache Storm
У меня есть штормовое приложение и пользовательский класс POJO (Alerts). Я добавил этот класс в объект конфигурации шторма. Класс оповещений реализует java.io.Serailable интерфейс и он также имеет serialVersionUID, conf.registerSerialization(Alerts.…
06 ноя '15 в 15:47
0
ответов
Могу ли я сделать так, чтобы пользовательский интерфейс Storm ожидал другого участника службы от "HTTP"
У меня есть Storm, работающий над своей собственной областью Kerberos, но для того, чтобы подключиться к моей корпоративной сфере, я обязан их правилам. Производственный AD только один, поэтому мне нужно сделать не-prod и prod-версии всех принципало…
11 апр '17 в 13:24
1
ответ
Datatorrent -Apex - Невозможно запустить приложение
Несколько дней назад я быстро установил Apex Datatorrent на свой кластер. Сегодня я пытаюсь запустить задание wordcount на datatorrent, но при запуске приложения выдает ошибку ниже. Ошибка LICENSE_MANAGER_ERROR Невозможно получить информацию о лицен…
29 июл '15 в 12:48
1
ответ
MLlib: для автономного обучения, Storm: использовать (развернуть) изученную модель
Можно ли обучить модель с помощью MLlib и использовать ее в топологии Storm? Я получаю набор отзывов от пользователей и планирую дать рекомендации.
14 мар '16 в 14:36
0
ответов
Сколько потоков может обрабатывать топология одного шторма?
У меня одна топология с двумя носиками и двумя болтами. Каждый носик действует как TCP-сервер. В любой момент только один TCP-сервер принимает данные. Два TCP-сервера не могут принимать данные параллельно. Пробовал то же самое с двумя разными тополо…
07 июн '17 в 09:09
0
ответов
Рабочие Apache Storm не запускаются
Шторм релиз 1.0.1, Мой нимб и супервайзер бегут. Когда я отправляю ExclamationTopology, что в storm-starterрабочий не запускается и нет worker.log, Я нахожу ошибку здесь от supervisor.log. Большое спасибо за ваше предложение.
20 дек '16 в 00:58
0
ответов
Не удалось запустить компонент [StandardEngine[Tomcat]
У меня есть проект весенней загрузки, и я интегрировал его сСтром и Какфа Когда я запускаю проект в файле eclispse works, когда я извлекаю из него jar и запускаю, я получаю следующую ошибку: Сбой дочернего контейнера во время запуска java.util.concu…
28 июн '18 в 06:57
1
ответ
Есть ли ограничение размера кластера Apache Storm?
Я предполагаю, что наличие большего количества узлов в грозовом кластере увеличивает внутрикластерное взаимодействие "keep-topology-alive". Учитывая, что топология отлично работает с 10 узлами (2 или 4 ЦП, 4 ГБ ОЗУ) для небольших данных, можем ли мы…
26 фев '16 в 08:59
0
ответов
Использование Maven для создания проекта Storm, но не могу найти полученный Java-проект
Я получил следующий вывод после выполнения команды "mvn eclipse:eclipse".Он показал, что сборка прошла успешно, но никакого Java-проекта там не было. Я не мог понять, почему. [INFO] Scanning for projects... [WARNING] [WARNING] Some problems were enc…
30 май '14 в 21:00
1
ответ
Storm Kafka Spout не фиксирует смещение в локальном кластере, spout получает одно и то же сообщение повторно
Я установил топологию шторма, которая получает входные данные с сервера kafka. Я использовал пакет kafka-storm для получения данных. Я успешно установил соединение между сервером kafka и топологией шторма в локальном кластере, но столкнулся с некото…
06 фев '15 в 11:16
7
ответов
Настройка топологии шторма
Как вы предоставляете пользовательскую конфигурацию для топологии шторма? Например, если у меня есть построенная топология, которая подключается к кластеру MySQL, и я хочу иметь возможность изменять, к каким серверам мне нужно подключаться, без пере…
05 авг '13 в 14:58
0
ответов
Изменение конфигурации Cassandra во время выполнения в Storm
Я использую шторм Кассад шторм-Кассандра Он настроен и работает, но у меня есть две проблемы: У меня есть 2 центра обработки данных, и если один из них выходит из строя, я хочу загрузить информацию в другой. Вопрос в том, как изменить конфигурацию в…
21 мар '17 в 15:58