Есть много вопросов, сравнивающих Flink и Spark Streaming, Flink vs Storm и Storm vs Heron. Этот вопрос возникает из-за того, что и Apache Flink, и Twitter Heron являются настоящими фреймворками потоковой обработки (а не микропакетами, такими как...

Я работаю над проектом IoT, где получаю поток данных по протоколу CoAP. Я хочу обработать данные в Heron, выполнив некоторые преобразования поверх них. Можно ли интегрировать объекты протокола CoAP в heron?

Я использую Heron для выполнения потоковой аналитики данных IoT. На данный момент в архитектуре есть только один носик с коэффициентом параллелизма 1. Я пытаюсь сравнить статистику по объему данных, которые Heron может хранить в очереди, которую...

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

Когда я использовал версию heron 0.17.1, я могу настроить файл ядра следующим образом: # location of the core package heron.package.core.uri: "/heron/dist/heron-core.tar.gz" # Whether role/env is required to submit a...

Когда я запускаю топологию Storm с KafkaSpout в Heron , происходит следующее exception : [2018-11-01 22:43:49 +0800] [INFO] com.twitter.heron.instance.HeronInstance: Starting instance container_2_ads_2 for topology AdvertisingTopology and...