apache-storm

1열

1답변

BaseRichSpout - Apache Storm의 fail() 메소드에서 실패의 근원을 찾는 방법? 다음과 같이

내가 토폴로지를 가지고 : Bolt1이 튜플을받는 곳 르네가 Bolt2 및 기타 스트림에 의해 가입 된 스트림 "mystream"을 가지고 Spout --> Bolt 1 --> Bolt2 --> Bolt3 을 "bolt1stream"입니다. (내 경우에는 Bolt2) 튜플의 실패의 경우 , 나는이 들어 Bolt1에서 다시는 Bolt2에서 재생을하고 싶습

java apache-storm 2016-09-13

---

0열

1답변

Apache Storm 릴리스의 차이점은 무엇입니까?

아파치 스톰 (http://storm.apache.org/downloads.html가) 있습니다 현재 1.0.x로 출시 : 아파치 폭풍-1.0.2.tar.gz 현재 0.10.x 자료 : 아파치 - 폭풍 0.10.1.tar을 에 .gz 현재 0.9.x 출시 : 아파치 폭풍-0.9.7.tar.gz 모든 버전의 차이점은 무엇 ? 이에 대한 정보를 찾을 수 없습니

apache-storm 2016-09-14

---

0열

1답변

Storm - KafkaSpout이 open()에서 실패했습니다.

지난 2 일 동안 저는 토폴로지 내에서 KafkaSpout을 구현하려고했습니다. 여기 은 중요한 정보입니다. 세 가지 서비스가 모두 동일한 인스턴스에서 실행됩니다. Kafka의 브로커는 기본적으로 9092 포트를 사용하고 advertised.listeners은 PLAINTEXT://localhost:9092으로 설정합니다. Zookeeper는 기본값 클라이

apache-kafka apache-storm 2016-09-16

---

3열

1답변

Clojure에서 멀티 스레드 프로그램의 리소스를 초기화하는 올바른 방법은 무엇입니까

저는 구성 요소와 시스템을 알고 있지만 (사용하지는 않았지만) init 메소드를 사용할 때 자원을 초기화하는 방법을 알고 싶습니다. 모든 스레드에서 실행할 수 있습니다. 우리가 10 개의 쓰레드를 가지고 있고, 모두 db를 사용한다고하자. 그리고 쓰레드는 어떤 순서로도 시작할 수있다. 어떻게 이런 경우 db 연결 풀을 초기화합니까? 현재이 설정을 사용하여

multithreading clojure apache-storm 2016-09-16

---

1열

1답변

폭풍의 시각화에서 화살표의 숫자는 무엇입니까?

토폴로지를 제출 한 후 폭풍 visulaization와 함께 다음 그림을 얻었지만 화살표에 숫자가 무엇인지 얻지 못했습니까? 나는 어떤 clarifaction를 얻기 위해 더 많은 검색하지만 어떤 도움이 잘못된 경우

apache-storm 2016-09-17

---

0열

2답변

스톰 : Kafka에서 HDFS로 - 종속 항아리 문제

나는 kafka에서 데이터를 소비하고 hdfs에 쓰는 폭풍 토폴로지를 구축했습니다. 카프카 폭풍 &를 사용 <storm.version>0.10.0.2.3.4.0-3485</storm.version> <kafka.version>0.8.2.1</kafka.version> 토폴로지는 아래에 명시된 예외 실패, 아래와 같이 종속 관계 : java.lang.N

hadoop hdfs apache-kafka apache-storm kafka-consumer-api 2016-09-17

---

0열

1답변

폭풍 kafka 스파우터를 해결하는 방법 kafka에서 소비자의 절반 데이터?

<dependency> <groupId>org.apache.storm</groupId> <artifactId>storm-core</artifactId> <version>1.0.2</version> <scope>provided</scope> </dependency> <dependency> <groupI

java maven apache-kafka apache-storm 2016-09-21

---

0열

1답변

Apache Storm Flux의 외부 속성을 입력하십시오.

Flux 1.0.0을 사용 중이며 토폴로지를 YAML 파일로 다시 작성했습니다. 하지만 스톰 드라이버를 사용하여 실행하는 구성의 일부였던 일부 속성이 있습니다. storm.Driver --config myConfig/config.conf 지금 스톰 플럭스와 함께, 어떻게 내 토폴로지에 config.conf에있는 속성을 주입 할 수 있습니까? 나는 현재 ja

apache-storm apache-storm-flux 2016-09-26

---

0열

1답변

새 Kafka 소비자 API로 샘플 카프카 주둥이를 쓰는 방법은 무엇입니까?

likes storm-kafka-client, 나는 storm-kafka-client에서 사용되었지만 잘 작동하지 않으며 새로운 스파우트도 쓸 수 없다고 쓰고 있습니다. 누가 샘플 카프카 스파우트를 쓸 수 있도록 도와 줄 수 있습니까?

apache-kafka apache-storm producer-consumer kafka-consumer-api 2016-09-27

---

1열

1답변

NoClassDefFoundError StanfordCoreNLP

local mode에 토폴로지를 제출할 때이 문제가 있습니다! ERROR backtype.storm.util - Async loop died! java.lang.NoClassDefFoundError: edu/stanford/nlp/pipeline/StanfordCoreNLP at edu.stanford.nlp.pipeline.NLP.init(NLP.ja

java nlp stanford-nlp apache-storm sentiment-analysis 2016-09-30

---