apache-storm

0熱度

2回答

我是Apache Storm的新手，目前我正在開發一個使用風暴的項目。在試圖理解風暴的基礎知識的同時，我遇到了靈光和監督員。我開始建立一個遠程集羣。我編輯了storm.yaml文件並將nimbus和zookeeper設置爲localhost。我嘗試在我的本地機器上運行我的靈氣，動物園管理員。我使用「風暴靈氣」啓動靈氣，但靈氣沒有啓動，而我的動物園管理員正在運行。 enter image descr

0熱度

1回答

風暴雨雲守護進程錯誤

我試圖在我的Ubuntu上運行Apache風暴。爲此，我應該運行nimbus守護進程。問題是，當我鍵入命令風暴靈氣，它給了我一個錯誤： ERROR StatusLogger File not found in file system or classpath: /usr/lib/storm/cluster.xml ERROR StatusLogger Reconfiguration failed

0熱度

1回答

org.apache.storm.multilang.NoOutputException：管道到子進程似乎被破壞！蟒蛇：無法打開文件[錯誤2]沒有這樣的文件或目錄

每當我嘗試在本地運行我的風暴拓撲我得到以下錯誤： java.lang.RuntimeException: org.apache.storm.multilang.NoOutputException: Pipe to subprocess seems to be broken! No output read. Serializer Exception: python: can't open file

1熱度

1回答

流媒體應用程序的時間序列窗口

我們正在開發使用Kafka，storm和redis的數據管道應用程序。來自不同系統的實時事件將發佈給Kafka，風暴根據配置的規則進行事件處理。狀態由redis管理。我們有不同的事件處理之前實現不同WAIT_TIME的要求。我們正在尋找以下選項。我們最初看着風暴窗[滑動或翻滾窗口]，但提供選項僅配置固定的時間間隔。我們需要基於規則的不同wait_time 我們正在探索將事件存儲在redis緩存

0熱度

4回答

阿帕奇風暴不能訪問UI

我的Apache風暴-1.1.0，試圖獲得在localhost風暴UI：8080，有這樣的： org.apache.storm.utils.NimbusLeaderNotFoundException：無法從種子主機[localhost]找到領導靈魂。您是否爲config nimbus.seeds指定了一個有效的nimbus主機列表？在org.apache.storm.utils.NimbusC

0熱度

1回答

風暴殺拓撲名[-w等待時間-秒]

我要殺死與等待時間秒= 1秒 storm kill topology-name [-w 1] 爲該語法是正確的拓撲結構？否則，如何使用-w標誌？給出任何示例以等待時間秒來殺死風暴拓撲？

1熱度

1回答

噴口類中的我的失敗方法只適用於第一個螺栓，從第二個螺栓到其不工作。

注： Bolt1包含前三個素數（2,3,5）的列表。 Bolt2包含第二組素數（7,11,13）的列表。在Bolt3中，只檢查數字是否爲素數。從第一個螺栓，我能夠從噴口類調用Fail（），但從第二個螺栓向前，我不能從噴口類調用Fail（）。拓撲類： ...... TopologyBuilder builder = new TopologyBuilder(); bui

2熱度

1回答

如何使用Twitter Heron與Storm Flux

我正在嘗試將項目從apache-storm遷移到twitter-heron。經過很多努力，我能夠擺脫大部分錯誤，例如使用className: "org.apache.storm.kafka.ZkHosts"而不是className: "storm.kafka.ZkHosts"。但是，我堅持提交拓撲。我使用Flux將拓撲提交給風暴。當我在ZkState中創建一個CuratorFramework對象

0熱度

1回答

在本地運行Storm拓撲時出錯

我想在localmode中運行Storm拓撲來測試它。該項目實質上是從卡夫卡壺中取出一些日誌，進行一些預處理操作，然後將內容打印在屏幕上。以下是我的拓撲代碼： import org.apache.storm.*; import org.apache.storm.generated.*; import org.apache.storm.kafka.*; import org.apache.s

0熱度

1回答

風暴三叉戟在網絡分區和/或故障場景中的確切一次保證

因此，Apache Storm + Trident提供了完全一次的語義。想象我有以下拓撲：在存儲器 TridentSpout -> SumMoneyBolt -> SaveMoneyBolt -> Persistent Storage. CalculateMoneyBolt總和的貨幣值，然後將結果傳遞給SaveMoneyBolt應的最終值保存到遠程存儲/數據庫。現在，我們計算這些值並僅存儲一