apache-storm

0열

1답변

스톰 토폴로지의 전체 대기 시간이 볼트의 합계와 같거나 (또는 가까운) 있습니까?

일반적으로 정상적으로 작동하는 폭풍 토폴로지가 있습니다. 우리는 로그에 오류가 없으며 시간이 빠릅니다.이 그래서 내 질문은 : 무엇이 더 많은 수의 전체 대기 시간이 발생하지만 때때로 우리는 "완전한 지연"여기 개별 볼트 있습니다에 스파이크를 얻을 개별 볼트보다? (Microsoft Spout 및 이벤트 허브가 도움이되는 경우이를 사용하고 있습니다.)

0열

1답변

폭풍 - 감독관이 발사되었지만 후광에 연결되지 않았습니다.

나는 1 명의 후광, 4 명의 수퍼바이저 및 2 개의 사육사 노드가있는 스톰 클러스터를 가지고 있습니다. 내 Storm.yaml는 다음과 같습니다 : storm.zookeeper.servers: - "storage14" - "storage15" nimbus.seeds: ["storage01"] #storm.local.hostname

0열

1답변

격리 된 두 개의 폭풍우 클러스터에서 단일 데이터 소스로 보내는 데이터를 동기화하는 방법

동일한 토폴로지를 실행하는 2 개의 격리 된 폭풍우 클러스터가 있습니다 (장애 조치 용). 이제는 주어진 시간에 단 하나의 설정에서 데이터 소스로 데이터를 보내야합니다 (따라서 싱크대의 데이터를 복제하지 않도록). 가급적이면 이음매가 없어야하지만 스위칭간에 최소한의 중단 시간 만 있으면됩니다. 이것을 달성하기 위해 어떤 동기화 메커니즘을 사용할 수 있습니까

0열

1답변

스톰 예제 오류

로컬 모드에서 간단한 단어 개수 토폴로지를 실행 중입니다. Intellij IDE로 토폴로지를 실행하면 모든 것이 완벽하게 작동하고 문자열에서 단어 수가 계산됩니다. 그러나 토폴로지를 실행할 때 A JNI error has occurred, please check your installation and try again Exception in thread

0열

1답변

"b.s.m.n.Client [ERROR] 연결 시도 22"오류가 발생할 수 있습니까?

4 개의 가상 시스템 클러스터에 Apache Storm 버전 0.9.6을 배포했습니다. 카프카 브로커 (kafka brokers)에서 데이터를 읽으려는 카프카 스파우트를 사용하고 있습니다. 나는 카프카 브로커와 스톰 노드를 동일한 가상 머신에 배치하고 있습니다. 죄송합니다.이 오류가 발생합니다 : b.s.m.n.Client [ERROR] connection

0열

1답변

스톰은 일괄 학습에 적합하지 않습니까?

그물에있는 다양한 출처에서 폭풍은 (사모아를 통해) 몇 가지 기계 학습 기능을 가지고 있지만 이해는 온라인 학습을 위해 항상입니까? 결론적 인 질문 : 스톰이 이러한 종류의 처리의 본질적인 반복적 특성 때문에보다 고전적인 배치 학습에 적합하지 않다고 말하는 것이 잘못 되었습니까? 설명해 주셔서 감사합니다.

1열

1답변

storm spout에서 BlockingQueue를 공유합니다.

두 개의 스레드가 동시에 실행되는 큰 데이터 응용 프로그램을 프로그래밍하고 있습니다. 쓰레드 A는 네트워크로부터 데이터를 받아 BlockingQueue에 JSONOBJECT로 저장한다. storm spout 인 Thread B가 BlockingQueue에서 읽고 처리합니다. 클래스 생성자의 Spout 클래스에 BlockingQueue 객체를 전달합니다. 내

0열

1답변

스톰 볼트의 지연 시간 측정

토폴로지에서 각 볼트의 대기 시간을 측정하려고합니다. 우리가 백분위 수를 계산할 때 Storm이 제공 한 대기 시간 수는 충분하지 않습니다. 현재의 셋업에서는 emit 호출을 포함하여 execute 메소드를 완료하는 데 걸리는 시간을 측정하여 볼트의 대기 시간을 측정합니다. 위의 방법을 가정하면 토폴로지의 현재 볼트 인스턴스와 다음 볼트 인스턴스간에 동일한

0열

2답변

sl4j 버전이 스톰 1.0.1 및 elasticsearch 5.2와 충돌합니다.

우리는 스톰 1.0.1 및 탄성 검색 5.2가있는 gradle에서 sl4j 버전 충돌에 직면하고 있습니다. 우리는 ElasticSearch가 원하는 로거를 사용할 수 있도록 log4j-to-slf4j 브릿지가 필요하다는 것을 발견했습니다. 여기서 우리는 logback-classic을 slf4j와 함께 사용하려고합니다. 토폴로지 때 configurations

0열

1답변

스톰 토폴로지와 서버의 HBase 연결

HBase를 서버의 도커에 저장했습니다. 나는 HBaseBolt를 포함하는 스톰 토폴로지를 생성하고 난 코드를 아래와 같이 HBaseBolt 연결 : TopologyBuilder builder = new TopologyBuilder(); ... builder.setBolt("indexer", new HBaseBolt("webpage", m