Вопросы с тегом 'apache-storm'

Количество результатов: 490

0 голосов
1 ответ
Убийство Бури топологии однажды носик заканчивается

Я создал топологию Бури с носиком, испускающий ряд кортежей для сравнительного анализа. Я хочу, чтобы остановить/убить мою топологию, когда все кортежи не вылетают из ...

0 голосов
2 ответа
Apache Буря с Кафкой смещением управления

Я построил пример топологии с использованием Сторм Кафку в качестве источника. Вот проблема, для которой мне нужно решение. Каждый раз, когда я убиваю топологию и зап...

0 голосов
1 ответ
Как измерить время, прошедшее между нитью в Apache Шторма?

Я получаю метрики болтов Шторма и носики, используя [codahale-метрику] и отправки на сервер Graphite. Как получить время для отправки сообщений между болтами и носикам...

0 голосов
1 ответ
Как отправить латентности метрики от Apache Шторма на сервер Графит?

Я настроил Apache Шторм метрик отправки на сервер с помощью графита версия 2. Он посылает count параметр всех моих болтов и желобов. Я хотел бы послать задержку между ...

1 голос
1 ответ
Apache Сторм против Apache Airflow

Какая разница между двумя? Насколько я понимаю, оба они основаны на концепции направленного ациклического графа (DAG) и штормовым обрабатывает данные в режиме реальног...

0 голосов
1 ответ
Как испускают метрики от удаленного работника Бури на сервер Графит при использовании настраиваемого IScheduler?

Я собирала метрики хорошо от Apache Шторма графита. Тогда я разработал индивидуальный планировщик, который реализует интерфейс IScheduler, и теперь я не могу собирать ...

0 голосов
0 ответов
Apache Буря носик не подключен MQ после перезапуска диспетчера

У меня есть приложение штормового апачского где работают все Zookeeper, нимб и супервизор. Через несколько часов мы не смогли подключиться к MQ и по истечении заданног...

0 голосов
1 ответ
как уменьшить масштаб штормового кластера (автономный один руководитель аппарата)

в качестве заголовка. Я есть штормовой кластер с 20 машин, один для венчика, и 19 для супервизора. Теперь я понял, что нам не нужны так много машин для ливневого клас...

0 голосов
2 ответа
Прозрачный Streaming & Пакетная обработка

Я еще совсем новичок в мире потока и пакетной обработки и пытается understnad понятий и гаджи. Это Admitedly очень возможно, что ответ на мой вопрос, хорошо известно, ...

0 голосов
1 ответ
Сигар UnsatisfiedLinkError на Apache Бури топологии

Я развертывание топологии Бури на моей машине, выполненную в виде одного локального кластера. Я настроен conf/storm.yaml использовать storm.scheduler: "org.apache.stor...

0 голосов
1 ответ
Буря + Кафка не распараллеливание, как и ожидалось

Мы имеем вопрос о параллельности задач внутри одной топологии. Мы не можем управлять, чтобы получить хороший, свободно скорость обработки. Мы используем Кафку и шторм...

1 голос
1 ответ
Ресурс очистки после убийства топологии штормовой

Мы имеем топологию штормовой, которая взаимодействует с базой данных MariaDB. Наши Болты реализовать IRichBolt интерфейс и переопределить методы жизненного цикла. Мы о...

0 голосов
1 ответ
Storm-Кафка-MongoDB интеграции

Я читаю 500 MB случайных кортежи от производителя Кафки непрерывного и в топологии штормового Я вставив его MongoDb используя Монго Java Driver. Проблема я получаю оче...

0 голосов
1 ответ
Как отправить несколько (разные) кортежи от одного KafkaSpout сразу болт?

Я новичок в Apache Storm. Я пытаюсь разработать систему обработки потока в реальном времени с помощью Apache Кафку, Storm и двигатель ESPER КЭП. Для этого, я имею од...

0 голосов
1 ответ
Окно параллелизм в Apache шторме

Я хочу, чтобы распараллелить работу окна в Apache бурей или другими словами распределенной операции окна. Мне нужно сравнить производительность когда мы бежим окно в о...

0 голосов
1 ответ
Отказ использовать ливневых стартер в IntelliJ, не может найти много зависимости

Я хочу использовать ливневых стартер в IntelliJ Я конфиг строг в качестве официального сайта https://github.com/apache/storm/tree/master/examples/storm-starter сказал...

0 голосов
1 ответ
ClassNotFoundException: clojure.lang.PersistentList, компиляции: (Clojure/core.clj: 20: 8) при подаче на топологию локального кластера в шторм

Я новичок в Apache Шторма, и я пытаюсь создать топологию в шторм, который может быть использован для обработки в режиме реального времени потоков. Но когда я пытаюсь п...

0 голосов
0 ответов
CONFIGURE elasticsearch APM с Apache Бури

Пытаюсь получить в режиме реального времени данные о topoloiges, работающих в Apache Бури с помощью Elasticsearch APM. Во время представления топологии, передают необ...

0 голосов
1 ответ
Является ли S3 для Apache Бури носик доступны?

Мне нужно прочитать новые файлы, поступающие на S3 с Apache Буря носиком. Имеют ли Apache Сторма есть носик, чтобы прочитать данные из S3 непосредственно? Я пытался на...

0 голосов
1 ответ
Неправильное разрешение хозяина Nimbus

Я бегу Apache Бури Nimbus и супервизора внутри отдельных докеров контейнеров, используя https://hub.docker.com/_/storm/. Контейнеры, работающие на том же экземпляре AW...

0 голосов
1 ответ
Apache Сторм JAR Access После развертывания

Я разработал приложение Java для запуска на Apache Storm. Мы будем устанавливать приложения на компьютерах клиентов, и мы хотим, чтобы клиент не имеет доступа к кодам ...

0 голосов
0 ответов
Развертывание Исключение приложения Apache Бури

При попытке развернуть банку Apache шторм, который я разработал с помощью Flux, я получаю следующее сообщение об ошибке введите описание ссылки здесь Мой Flux файл зд...

0 голосов
2 ответа
Возможно передавать данные из Nifi Спарк Structured Streaming/Storm непосредственно без потери данных?

В моем текущем сценарии; Nifi собирает данные, а затем отправляет Кафка. Тогда любой потоковый двигатель потребляет данные из Кафки и анализа. В этой ситуации; Я не хо...

0 голосов
0 ответов
Как ограничить использование памяти с помощью болта?

Я создал топологию, которая имеет 1 носик и 2 экземпляра болта, каждый из них работает на другой рабочий. И выделено 2048 МБ для каждого из них с помощью «childpots». ...

0 голосов
0 ответов
Сколько болтов я должен использовать для этого потока топологии ливневой?

Рассмотрим следующий мошеннической кредитной карты сценарий обнаружения транзакций. Сделки прибывают в центре обработки данных от одного носика. Вы хотите, чтобы обнар...

0 голосов
2 ответа
Получение ClassNotFoundException с помощью новой версии 2.1.0 Кафки с Apache Бурей 1.2.2 в Кафке носике

При запуске топологии с Кафкой носиком с новой Кафки версией 2.1.0 и штормовой версией 1.2.2, получить java.lang.ClassNotFoundException: kafka.api.OffsetRequest. Я не ...

1 голос
1 ответ
NoClassDefFoundError: Maven межмодульной зависимость

У меня есть проект Сторм приложение (Maven) структурирована следующим образом: parent-project/ ├── pom.xml ├── storm-application/ └── pom.xml ├── utils/ └── p...

0 голосов
1 ответ
Apache Кафка смещения фиксации в апаче топологии ливневой

Я проектирование топологии апача штормовой (используя streamparse), построенная с одним носиком (Apache Kafka носика) и 1 болтом с параллелизмом> 1, что читать сообщен...

0 голосов
2 ответа
Потоковая обработка данных и нано разрешение второго раза

Я только начинаю в тему в режиме реального времени базы данных для обработки потока, и у меня есть вопрос, на который я пока еще не удалось найти какой-либо однозначны...

0 голосов
1 ответ
Как добавить файл банки в Apache Буря EXTLIB в выполнении/нет перезагрузки?

Я хочу, чтобы добавить новую логику в новой баночке файл в Apache шторм, когда он работает. Способ накормить его новые баночки, чтобы скопировать их в свою extlib. Воп...

0 голосов
1 ответ
org.apache.storm.utils.NimbusLeaderNotFoundException: Не удалось найти лидера нимб из семян хостов

Я получаю сообщение ниже. Не удалось найти лидера нимб из семян хозяев [мастер]. Правильно ли вы указали   действительный список нимба хосты для конфигурации nimbu...

0 голосов
1 ответ
Манипуляция топологии ливневой

Я новичок в Apache Storm..I'm пытаюсь сделать что-то, но я не знаю, если это возможно .. Я создал прямой график, и я хотел бы обратиться к топологии штормового Я следс...

0 голосов
1 ответ
Как исправить ошибку Java виртуальная машина не найдена ошибка в Apache Storm?

Я устанавливаю Apache Storm в распределенном режиме. Мой зоопарк работает нормально. Я не могу даже запустить Apache Storm Nimbus. Я следую: http://chennaihug.org/kno...

0 голосов
1 ответ
apache storm - правильно запускать jar в одном узле, но не в нескольких узлах

Я новичок в Apache Storm, я написал код, который включает в себя 1 носик и 2 болта, когда я запускаю эти 3 части на одном работнике, код генерирует вывод правильно, но...

0 голосов
0 ответов
Apache Storm JdbcInsertBolt с дозированием

Мне нужно вставить записи в пакетном режиме в мою таблицу postgres с помощью шторма. я нашел JdbcInsertBolt (посмотреть здесь) это полезно для достижения этой цели. Но...

0 голосов
1 ответ
Остановка служб Apache Storm

Я устанавливаю шторм в среду на работе, но в настоящее время работает только служба Nimbus. Когда я запускаю Supervisor/Ui, они работают около 30 секунд/минуту, прежде...

0 голосов
1 ответ
Позволяет ли Apache Storm обрабатывать объемные файлы, хранящиеся в HDFS?

Позволяет ли Apache Storm обрабатывать объемные файлы, хранящиеся в HDFS? зная, что моя цель - получить ответ в реальном времени (секунды или миллисекунды), или Apa...

0 голосов
1 ответ
Настройка входа с помощью Storm

У меня есть проект шторма, для которого я добавил несколько пользовательских конфигураций входа logback.xml (добавлены конфиги для записи логов в индекс). Когда я соби...

0 голосов
0 ответов
Бенчмаркинг для Самзы, Искры, Шторма и Флинка

Я попытался установить некоторые тесты там. Наиболее включают в себя один yahoo Streaming Bench. Но он устарел, с ошибочными настройками и устаревшими зависимостями. Н...

0 голосов
1 ответ
Найдите слово, имеющее максимальное количество, используя топологию Trident

Как найти слово с максимальным количеством в топологии подсчета слов, используя топологию Trident? Вот ссылка на топологию подсчета слов Trident. https://github.com/na...

-1 голос
1 ответ
Commons Logging версия конфликта между StormCrawler и Hortonworks 1.1.0.2.6.4.0-91

Я следовал http://stormcrawler.net/getting-started/ руководство для создания файла фляги для topology.When я запустить топологию с помощью команды ливневых в readme фа...

0 голосов
1 ответ
Stormcrawler не выборки/индексации страниц для elasticsearch

Я использую Stormcrawler с Elasticsearch пример и никакие страницы не отображаются с FETCHED статус в Kibana при сканировании веб-страницы http://books.toscrape.com/ ...

2 голоса
1 ответ
топология архетип StormCrawler в вообще не получает внешних ссылок

Из моего понимания основной пример должен иметь возможность сканировать и получать страницы. Я последовал примеру на http://stormcrawler.net/getting-started/ но иска...

0 голосов
1 ответ
Советы, необходимые для масштабируемой архитектуры обработки сигналов с Штормом

Мы разрабатываем платформу обработки сигналов IoT, основанную на STORM, с горизонтальной масштабируемостью в виде. Эта платформа предназначена для обработки несколько ...

0 голосов
1 ответ
Правильный способ изведа/якорные Грозовые кортежи

У меня есть болт, который работает в небольших партиях кортежей. Я по существу есть switch утверждение, что прослушивает либо поток из предыдущего болта или tick tuple...

0 голосов
1 ответ
Развертывание 2 различных топологий на одном Nimbus с 2 другими аппаратными средствами

У меня есть 2 комплекта штормовых топологий, используемых сегодня, один вверх 24/7, и это делает свою собственную работу.Другой, развертывается по требованию, и обраба...

0 голосов
1 ответ
Высокая латентность между носиком -> болт и болт -> болты

В моей топологии я вижу вокруг 1 - 2 мс латентности при передаче кортежи из желобов на болты или болты на болты. Я расчет задержка с использованием наносекундных меток...

0 голосов
3 ответа
Как реализовать собственный планировщик в Герона?

Я прочитал Heron Documents около Implementing a Custom Scheduler. И я знал, что я должен реализовывать несколько интерфейсов для реализации пользовательского планировщ...

1 голос
1 ответ
Apache Буря: исключение представления топологии: [х] выписывает из несуществующего потока

Извините, если вопрос решен, но я пытался найти его, и я не имел успеха. Есть несколько подобных, но я не нашел помощи, где я видел. У меня есть следующая проблема: 6...

0 голосов
1 ответ
настройки StormCrawler

У меня есть несколько вопросов о StormCrawler: http://stormcrawler.net/ 1. Запретить искатель Магазины: Я пытался использовать это регулярное выражение по умолчанию...

1 2 3 4 5 6 7 8 9 10 right