apache-storm

1熱度

1回答

我正在嘗試使Apache Storm Spout從一行文件中逐行讀取。我試圖寫這些陳述，但他們沒有奏效。它給我的第一行只重複每次： class SimSpout(storm.Spout): # Not much to do here for such a basic spout def initialize(self, conf, context): ## Open

0熱度

1回答

風暴 - 主管啓動但未連接到Nimbus

我有一個Storm集羣，有1個Nimbus，4個Supervisor和2個Zookeeper節點。我Storm.yaml是如下： storm.zookeeper.servers: - "storage14" - "storage15" nimbus.seeds: ["storage01"] #storm.local.hostname: "storage05" supe

1熱度

1回答

Storm Kafka-Spout不能正常工作

一般：我是一個想要在Storm/Kafka/Flink/MS Azure SA/Spark上運行一些性能測試（WordCount）的學生。我想使用Kafka Broker作爲輸入源。我從風暴啓動項目中使用的字計數實例，並添加卡夫卡作爲壺嘴： public class WordCountKafkaTopology { public static class SplitSentence e

0熱度

1回答

風暴不適合批量學習嗎？

從網絡上的各種資源中，我瞭解到Storm有一些機器學習功能（例如通過薩摩亞），但在線學習是否爲總是？推論問題：如果我說Storm不適合更經典的批次學習，那麼我錯了嗎？因爲這種處理的固有迭代性質？謝謝澄清。

1熱度

1回答

在暴風雨噴口共享一個BlockingQueue

我正在編寫一個大數據應用程序，其中兩個線程同時運行。線程A從網絡接收數據，並將它們作爲JSONOBJECT放在BlockingQueue中。線程B，一個風暴噴口，然後從BlockingQueue中讀取並處理它們。我將BlockingQueue對象傳遞給類構造函數中的spout類。我發現的問題是，噴嘴中的BlockingQueue是空的。你能不能讓我知道我該如何解決這個問題？

0熱度

2回答

sl4j版本與Storm 1.0.1和elasticsearch的Gradle衝突5.2

我們正在面對與Storm 1.0.1和elasticsearch 5.2的gradle中的sl4j版本衝突。我們發現ElasticSearch需要橋接log4j-to-slf4j，以便我們可以使用所需的記錄器。這裏我們試圖用slf4j來使用logback-classic。的依賴定義如下： dependencies { compile 'org.slf4j:slf4j-api:1.7

0熱度

1回答

風暴拓撲與服務器中的HBase之間的連接

我將HBase存儲在服務器中的docker上。我創建了一個風暴拓撲包含HBaseBolt和我連接HBaseBolt如下代碼： TopologyBuilder builder = new TopologyBuilder(); ... builder.setBolt("indexer", new HBaseBolt("webpage", mapper)).localOrShuffl

0熱度

1回答

Apache Storm＆Vagrant。 org.apache.storm.utils.NimbusLeaderNotFoundException

我是Apache Storm和Vagrant的新手，我想在使用Vagrant構建的虛擬化集羣上部署我的拓撲。但是我不斷地從風暴UI獲得org.apache.storm.utils.NimbusLeaderNotFoundException： org.apache.storm.utils.NimbusLeaderNotFoundException: Could not find leader nim

1熱度

1回答

風暴拓撲：正確的方法ACK當兩個螺栓有相同的源螺栓

我是相當新的風暴，最近改變了我的螺栓從IRichBolt 而不是BaseBasicBolt繼承，這意味着我現在負責ACKING的和失敗一個元組根據我自己的邏輯。 My topology looks like this: 螺栓A向螺栓B和C發出相同的元組，每個堅持數據到卡桑德拉。這些操作不是冪等的，並且包含對兩個不同計數器列族的更新。我只對失敗的元組感興趣，並在Cassandra的某些異常（不

0熱度

2回答

如何使用Apache風暴作爲複雜事件處理器

我一直在尋找一段時間如何使用Apache風暴作爲CEP，但它似乎有兩個概念（流處理和複雜事件處理）在CEP中你可以編寫sql-像查詢和他們在ESPER數據流上執行，但我不能在apache風暴中找到任何類似的東西，這是否意味着apache風暴是一個數據流處理器而不是CEP？