apache-storm

7зной

1ответ

Подключение базы данных штормовых болтов

Я использую Storm (java) с Cassandra. Один из моих болтов вставляет данные в Кассандру. Есть ли способ удерживать соединение с Cassandra открытым между экземплярами этого болта? Скорость записи прилож

0зной

1ответ

Исключение брошено при регистрации пользовательских сериализаторы в storm.yaml Шторма

Я зарегистрировал собственный сериалайзер для класса в Шторма Conf/storm.yaml следующим образом: topology.kryo.register: - custom.Car: custom.MyCarSerializer Когда я начал штурм, набрав "б

15зной

3ответ

как быстро увеличивать счетчики в Кассандре без застоя

У меня вопрос Кассандры. Вы знаете, как Cassandra обновляет/увеличивает счетчики? Я хочу использовать штурмовой болт (CassandraCounterBatchingBolt из storm-contrib repo on github), который записываетс

4зной

1ответ

При установке Storm мы получаем ошибку, которую супервизор не запускал. Что нам делать?

2013-04-04 14:02:39 b.s.d.supervisor [INFO] 07a06309-95f5-423b-999b-f5913388bb2e still hasn't started 2013-04-04 14:02:39 b.s.d.supervisor [INFO] 07a06309-95f5-423b-999b-f5913388bb2e still hasn't sta

2зной

1ответ

Что означают порядковые номера Storm Nimbus?

Я составил топологию. В состоянии nimbus у меня есть некоторая последовательность чисел, подобных этому executor->start-time-secs <[2 2]1389244616,[3 3]1389244616,[4 4]1389244616,[5 5]1389244616, Чт