apache-storm

1열

1답변

5 노드 클러스터에 storm-0.9.2를 설치했습니다. 나는 1 개의 스파우트와 다양한 수의 볼트 (4, 9, 22, 31)를 가진 간단한 토폴로지를 가지고 있습니다. 각 구성마다 (#bolts + 1) 개의 작업자를 구성했습니다. 따라서 4 개의 볼트에는 5 명의 작업자와 23 개의 작업자가있는 22 개의 볼트가 있습니다. zookeeper.out 로그

1열

1답변

Java에서 폭풍에 대해 별도의 Log4j 사용

안녕하세요, 저는 폭풍우를 사용하여 자바 프로그램에 폭풍우를 사용하고 있습니다. 이제 내 개인 정보 로거를 사용할 때 그 로그는 스톰 시스템 로그와 함께/storm/logs에 저장됩니다. 폭풍도 log4j를 사용한다는 것을 알고 있습니다. 이제는 내 Java 프로그램이 /home/mylog.out과 같은 다른 파일에 대해 별도의 log4j를 사용하면서 내

1열

3답변

java에서 폭풍의 상태를 확인하는 방법은 무엇입니까?

이제 로컬 컴퓨터에 스톰 클러스터를 구성했습니다. 이제 나는 폭풍우를 시작하기 전에 폭풍 명령에 의해 감독관과 후계자를 시작해야한다는 것을 알고 있습니다. 이제 Java 프로그램을 작성 중이며 작동중인 또는 작동하지 않는 폭풍우 클러스터의 상태를 확인하려고합니다. 처럼 : 지금은 내 폭풍 클러스터가 성공적 여부 실행되고 있는지 확인할 수있는 방법을 if(s

2열

1답변

폭풍 클러스터의 각 기계에 하나씩 특수 볼트를 지정하십시오.

클러스터의 모든 기계에서 특수 볼트를 시작하고 싶습니다. 스톰에는 플러 거블 스케줄러가 있지만 설명서가 거의 없습니다. xumingming에서 이해할 수있는 것은 example뿐입니다. IScheduler을 사용하여이 패턴을 어떻게 구현할 수 있습니까? 포트 8765. TCPBolt 병렬 == 클러스터 크기를 청취 우리는 TCPBolt이 예. 각 기계에서이

0열

1답변

폭풍우에 클러스터를 넣을 때 무슨 일이 일어나고 있습니까?

'폭풍 병'명령을 실행 한 후 Nimbus-Zookeeper-Supervisor-Workers가 작동하는 방식은 무엇입니까? 백그라운드에서 프로세스는 어떻게 될 것입니까?

0열

1답변

Twitter Storm 대신 메시지 대기열을 사용하는 것이 더 나은 경우

Twitter Storm에서 읽는 중입니다. 데이터 파이프 라인을 구축하기 위해 메시지 대기열보다 높은 추상화 수준을 제공하는 것처럼 보입니다. 스톰이 아닌 메시지 대기열을 사용하여 '베어 메탈'을 작동시키는 것이 바람직한 위치 (있는 경우)가 있는지 궁금합니다.

1열

1답변

탄성 검색/스톰 통합 방법

Elasticsearch와 Apache Storm 간의 간단한 통합 경로를 찾고 있습니다. 이것에 대한 지원은 elasticsearch-hadoop 라이브러리에 포함되어 있지만 Hadoop 스택에 종속성이 많습니다. Hive에서 Cascading에 이르기까지 간단히 말해서 필요하지 않습니다. 거기 밖으로 아무도 elasticsearch-hadoop을 데려

1열

2답변

이 스톰 토폴로지를 구현하려면 어떤 방법을 사용해야합니까?

난 폭풍 다음 토폴로지를 구현하려는 : B2 등 A1, B1 및 A2는 동일한 것을 볼트가 a1->a2->a3->a4 | | -<----<-- b1->b2->b3->b4 | | -<----<-- 참고. 두 개의 동일한 스트림이 있지만 볼트 사이에 전달 된 튜플은 스트림 내에 남아 있어야합니다. 또한 a4->

0열

1답변

storm hdfs 커넥터를 사용하여 HDFS에 데이터 쓰기

HDFS에 데이터를 쓰는 데 사용할 수있는 "storm-hdfs 커넥터"의 소스 코드입니다. github URL은 다음과 같습니다. https://github.com/ptgoetz/storm-hdfs 특정 토폴로지가 있습니다. "HdfsFileTopology"는 '|' 데이터를 HDFS로 분리합니다. 링크 : 나는 코드의 일부에 대한 질문이 https://

0열

1답변

Storm (v0.9.2-incubating) 시스템을 재부팅 한 후 관리자 시작 오류가 발생했습니다.

최근 VMWare를 사용하여 로컬 가상 시스템에 폭풍우를 배포했습니다. 배포 된 버전은 v0.9.2-incubating release version입니다. 제가 직면하고있는 문제는 모든 단일 재부팅 후에 '$ storm supervisor'가 작동하지 않는다는 것입니다. 바로 지금, storm.local.dir 디렉토리를 정리하기 위해 사용하고있는 비참한