apache-storm

0熱度

1回答

Storm ui錯誤：org.apache.storm.utils.NimbusLeaderNotFoundException：無法從種子主機中找到領導者靈氣[localhost]

我試圖在m Windows 7 64位機器上設置apache風暴。我的配置如下 - zoo.cfg tickTime=2000 initLimit=5 syncLimit=2 dataDir=C:/Server-Local/zookeeper-3.4.9/data clientPort=2181 storm.yaml storm.zookeeper.servers: - "

0熱度

1回答

找不到風暴logs目錄中STORM_HOME

當我安裝了暴風0.9.5在linux下，我無法找到日誌目錄照常運作正確的目錄是但實際上我得到的目錄如您所見，日誌目錄消失。我想知道爲什麼日誌目錄消失。我開始擔任主管風暴，結果仍然如此。

0熱度

1回答

BaseStatefulBolt（風暴核心）vs StateFactory（風暴三叉戟）

我對使用風暴感到困惑。我將使用流數據來衡量數據源的狀態。狀態將通過一些字段的組合來計算，並且這些字段可以實現不同的時間間隔。這就是爲什麼我需要保存字段來衡量數據源的狀態。我可以使用BaseStatefulBolt嗎？或者唯一的解決方案是三叉戟這個cenario？ btw他們有什麼區別。因爲在三叉戟內部也有一個statefactory。謝謝。

0熱度

2回答

KafkaSpout元組重播拋出空指針異常

我正在使用storm-kafka-client 1.0.3的風暴1.0.1和Kafka 0.10.0.0。請在下面找到代碼配置。 kafkaConsumerProps.put(KafkaSpoutConfig.Consumer.KEY_DESERIALIZER, "org.apache.kafka.common.serialization.ByteArrayDeserializer");

0熱度

1回答

ProcessSimulator.killAllProcesses（line：78）NoSuchMethodError ConcurrentHashMap.keySet（）

爲什麼？我使用暴風首次（從入門風暴學習），並運行成功，但發現的NoSuchMethodError： java.lang.NoSuchMethodError: java.util.concurrent.ConcurrentHashMap.keySet()Ljava/util/concurrent/ConcurrentHashMap$KeySetView; at org.apache.s

0熱度

1回答

如何在滑動窗口中獲取當前窗口時間？

我使用的風暴實現滑動窗口： From Here 這是我的拓撲結構： public static void main(String[] args) throws Exception { TopologyBuilder builder = new TopologyBuilder(); builder.setSpout("rabbitSpout", new RabbitMQSpou

0熱度

1回答

如何測試Storm中的Spouts

我正在努力完成一項測試我的Apache Storm spout的任務，該任務實際上是從隊列中讀取數據並將消息發送爲元組。我想使用嵌入式隊列，將消息放入隊列中，並將消息由我的噴嘴發出。任何人都可以幫助完成該操作？

0熱度

1回答

殺死拓撲名稱中包含特殊字符的Storm拓撲結構

因此，恰巧我從其中一個示例（storm-starter）獲得了Storm拓撲結構，部署的名稱爲-local。現在當我試圖kill時，它並不太高興，因爲名字被解釋爲一個參數。我曾嘗試通過（雙）引號等名稱徒勞。有沒有其他方法？

0熱度

1回答

噴口邏輯錯誤

在這個問題上我需要你的幫助。我讀到，噴口負責讀取數據或準備在Bolt中進行處理。所以我寫了一些代碼在噴口中打開文件並逐行讀取 class SimSpout(storm.Spout): # Not much to do here for such a basic spout def initialize(self, conf, context): ## Open the

0熱度

1回答

案例工作者在風暴中死亡的字段分組

我有一個用例，我正在使用本地緩存來維護某些ID的計數器。我在拓撲類中做了fieldsGrouping("spout", new Fields("id"))。假設id1總是在processingBolt上worker1和id2處理在processingBoltworker2總是得到處理。如果worker2死亡，將id2開始處理worker1？