apache-storm

2зной

1ответ

#Storm: как настроить различные показатели для одного и того же источника данных

Я пытаюсь настроить Storm для объединения потока, но с различными (доступными DRPC) метриками в том же потоке. E.g. поток состоит из сообщений, у которых есть отправитель, получатель, канал, через кот

1зной

1ответ

Запуск нескольких штормовых топологий в локальном режиме

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

10зной

1ответ

Как написать c +2 spout/bolt на использование Storm and Thrift в Storm

От here: Storm был разработан с самого начала, чтобы быть совместимым с несколькими языками. Nimbus - услуга Thrift, а топология определяется как структуры Trrift. Использование Thrift позволяет испол

2зной

1ответ

InvalidClassException локального класс несовместимые при запуске штурмовать топологию

Моего шторма приложение работает один топологию работает нормально при работе в локальном режиме, но при работе в распределенной среде я получаю эти исключения в моих журналах рабочих. Это одно и то ж

3зной

1ответ

Connection отказался ошибка в Буре

Я новичок в Буре .. Я stucked с ниже ошибками java.net.ConnectException: Connection refused at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) at sun.nio.ch.SocketChannelImpl.finish

6зной

2ответ

Развертывание топологий для разных удаленных кластеров?

Я разрабатываю топологии для бури (storm-project.net). У меня есть 2 удаленных кластера: постановка и производство. У меня есть два файла storm.yaml на клиенте (мой ноутбук, на котором я пишу код), ко

2зной

1ответ

шторм умирает, когда определенные узлы зоопарка сбой

У меня есть сервер nimbus и 3 узловых места. Мой файл storm.yaml выглядит следующим образом: storm.zookeeper.servers: - "server1" - "server2" - "server3" nimbus.host: "nimbus-server" storm.loca

6зной

1ответ

Process Complex Events

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