apache-storm

1熱度

1回答

OpenCV - Apache Storm發生'UnsatisfiedLinkError'

我正在使用（Apache Storm1.0.0 + OpenCV3.2.0）來分發處理視頻。我已經將拓撲提交給羣集，但工作人員似乎沒有工作。所以我檢查了噴出job(ReadStreamSpout.java: read file from local)的node3（worker）的日誌。 logs of node3 我真的不知道該怎麼形容更.... 請讓我知道我需要的信息。

1熱度

1回答

卡夫卡噴口集成

我正在使用卡夫卡0.10.1.1和風暴1.0.2。在kafka集成的風暴文檔中，我可以看到，使用zookeeper服務器初始化kafka spout時，仍然使用zookeeper維護偏移量。如何使用kafka服務器引導噴口。是否有任何示例。從使用動物園管理員風暴文檔 BrokerHosts hosts = new ZkHosts(zkConnString); SpoutConfig spout

1熱度

1回答

在風暴0.10.0 2工作進程啓動，即使當我設置工人= 1，和UI報告工人= 1

我有一個風暴拓撲我爲此：setNumWorkers（1）; 當我查看關於此運行拓撲的風暴UI報告時，我看到Num工作者設置爲「1」。但是，當我登錄到運行supervisor的節點時，我看到兩個進程具有相同的-Dworker.id和-Dworker.port設置。我包括'ps'的輸出顯示了我在下面的這兩個過程。我的問題是：爲什麼有兩個進程似乎配置爲工作進程，如果我只請求一個（注意：Storm U

0熱度

1回答

.avsc文件從卡阿Storm應用程序日誌模式下載，而不是的.jar

按照該kaa tutorial，它說 - 把你從管理員下載日誌架構（* .jar文件）庫UI放入$ {KAA_SAMPLE_HOME_DIR}/storm-server/lib目錄。但是當我下載日誌模式，它會下載爲.avsc文件，然後將下面的命令失敗：$ mvn clean install 雖然一切工作正常，如果上述文件沒有提及和說明直接從跟隨kaa沙箱。我仍然認爲，如果文檔可以被糾正，那麼定

0熱度

1回答

通過REST API部署Storm拓撲

有沒有通過某種REST端點部署Storm拓撲的方法？我見過Storm REST端點，我知道我可以激活或停用現有拓撲，但如果我想添加新拓撲，該怎麼辦？也許有某種出路......

0熱度

1回答

Apache風暴中的單元測試 - 使用BaseRichBolt超時但不使用BaseBasicBolt

我正在嘗試爲風暴螺栓（Java）實現單元測試。下面的代碼工作正常，並在風暴1.0.3與成功結束： Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 3.887 sec 然而，當我上線46改變BaseBasicParrotBolt到BaseRichParrotBolt，因此斷言不會運行，並將其與下面的異常結束： 13610

1熱度

1回答

HDInsight Storm無法使用示例應用程序讀/寫EventHubs

我試圖實施示例EventHub應用程序here，但它給了我錯誤。我遵循了文檔中給出的完全相同的步驟。我在HDInsight 3.5上，Storm 1.0.1.2.5.4.0-121 從Storm UI中可以看出，EventHubReader的功能如下。 com.microsoft.eventhubs.client.EventHubException: org.apache.qpid.amqp_1_

0熱度

1回答

HDFS的並行提示

我正在使用apache風暴並使用HDFS。如果我使用螺栓1的並行提示，並且它正在創建一個文件，請將數據寫入文件並正常工作。但是，當我將螺栓的並行提示增加到3時，它將創建3個文件並將數據寫入到一個文件中。我的應用程序具有一個噴管和兩個螺栓（Xbolt和Yblot）並行暗示如下噴嘴1，Xbolt 1，Ybolt 3 應用流噴 - > Xbolt - > Ybolt - >文件（S） Topol

1熱度

1回答

Apache Storm Supervisor錯誤：無法找到或加載主類org.apache.storm.daemon.supervisor

我收到以下錯誤，嘗試從Windows 7工作站啓動storm supervisor：錯誤：無法找到或加載主類org.apache.storm.daemon.supervisor。我能夠成功啓動nimbus，沒有任何錯誤。 P：最初我也遇到了同樣的問題。然後我遵循Apache Storm Nimbus Error: Could not find or load main class中給出的解決方案

0熱度

3回答

Esper和Apache Storm之間的區別？

我的目標是與出版商和消費者製作分佈式應用程序，我使用CEP處理數據流，以便爲事件消費者生成事件通知。 Esper和Apache Storm有什麼區別？我可以實現Storm只用Esper做什麼，我應該什麼時候考慮將Esper與Storm整合？我很困惑，我以爲Esper提供了相同的功能。