apache-storm

0열

1답변

저는 실시간 분석으로 문제를 해결하려고합니다. 실시간으로 값을 계산하고 싶습니다. 스트리밍 데이터를 수신하고 카프카 (Kafka)와 스톰 (Storm)으로 처리하고 마침내 레디 스 (Redis)에 기록합니다. 이제 Redis에 저장된 모든 데이터를 다시 Storm으로 밀어 넣고 끌어 당겨서 더 많은 계산을 수행하고 싶습니다. 문제는 매분마다 반복해야한다는

1열

1답변

Apache Storm 오류가 로컬 클러스터에서 토폴로지를 전송할 수 없습니다.

아래 jars와 함께 최신 버전의 폭풍을 사용하고 있습니다. 폭풍 코어 1.0.1 폭풍 카프카-1.0.1 사육사-3.4.8 kafka_2.10-0.9.0.1 storm-core-0.9.3와 함께 작동하지만 폭풍의 최신 버전과 함께 오류가 발생합니다. Exception in thread "main" java.lang.IllegalAccessError: tri

1열

1답변

Windows 8 또는 우분투 (VMware Player)에 Apache Storm이 있습니까?

Windows 8에 Apache Storm을 설치하려고하지만 이것이 최선의 선택인지 여부와이 작업을 수행하는 데 필요한 것이 확실하지 않습니다. 또는 우분투 대신 VM (VMware 플레이어)에 스톰을 설치하는 것이 좋습니다. 결국 EC2 Cloud에서 Apache Storm을 확장하려고합니다. 미리 알려 주셔서 감사합니다.

0열

1답변

Apache Storm이 제대로 실행되지 않고 worker.log에서 예외가 발생합니다.

Apache Kafka에서 Apache storm을 사용하고 있습니다. 사용 된 주둥이는 카프카 - 스파우트이지만 카프카 항목에서는 아무 것도 읽지 않습니다. 나는 그것이 폭풍우의 노동자들에게 직면하고있는 문제와 관련이 있는지 없는지 모른다. 관련 솔루션을 알고 계시면 알려 주시기 바랍니다. 스톰 토폴로지가 스톰에 성공적으로 업로드되었습니다. java.la

3열

1답변

Apache Storm Nimbus 오류 : 메인 클래스를 찾지 못하거나로드 할 수 없습니다.

다음과 같은 오류가 발생하여 로컬 Windows 7 워크 스테이션에 대해 폭풍우 비상구를 시작하십시오. Error : 메인 클래스 Files \ Java \ jdk1을 찾지 못하거나로드 할 수 없습니다. .8.0_92 \ 빈; C : \ 프로그램 storm.yaml : 나는 성공적으로 사육사를 시작 storm.zookeeper.servers: -

1열

1답변

Apache Storm Hbase 버전 호환성, java.lang.NoSuchFieldError : HBASE_CLIENT_LIMIT

다음 Storm setup (Ubuntu 16.4 64 비트에서)을 실행 중입니다. 스톰 : 0.10.1 하둡 : 2.5.2 (현지 의사 클러스터) HBase를 : 1.1.5 (현지 의사 클러스터) 병에 대한 컴파일러 : 받는다는 사용 기본 hbase storm은 import 함수를 통해 클래스를 지원합니다 : org.apache.storm.hbase.bo

0열

1답변

Nimbus 실패 후 관리자 재시작

Nimbus가 실패하고 그 후에 관리자가 실패하면 관리자를 다시 시작할 수 있습니까? 클라이언트가 그렇게 할 수 있습니까? 수동으로 할 수 있습니까? 또는 (또는) Nimbus를 수동으로 다시 시작해야하며 관리자가 다시 시작해야합니까?

0열

1답변

폭풍우에, 볼트가 달릴 노동자의 수를 지정할 수 있습니까?

트라이던트를 사용할 때 배치가 하나의 볼트로 처리되는 경우 다른 작업자로 배치를 실행할 수 있습니까?

2열

2답변

폭풍우를 사용하면 여러 입력이있는 볼트가 모든 입력이 도착한 경우에만 어떻게 처리 할 수 있습니까?

토폴로지는 다음과 같습니다. 어떻게 여러 입력이있는 볼트가 모든 입력이 도착할 때만 처리되도록 할 수 있습니까?

2열

2답변

log4j-over-slf4j.jar 및 slf4j-log4j12.jar가 충돌했습니다 ...하지만 slf4j-log4j12.jar이 없습니다

kafka, storm 및 druid를 통합하려고 할 때이 문제가 발생했습니다. 해당 버전은 다음과 같습니다는 kafka_2.11-0.8.2.2 druid-0.9.1.1 apache-storm-0.10.1 log4j-over-slf4j.jar and slf4j-log4j12.jar conflitct... but i don't have log4j-ov