apache-storm

0열

1답변

카프카 스파우트 작업이 여러 개있는 토폴로지가 있습니다. 각 스파우트 작업은 카프카 (Kafka) 주제 세트에서 메시지의 서브 세트를 읽어야합니다. 주제는 AAA.BBB. *와 같은 와일드 카드를 사용하여 구독해야합니다. 예상되는 동작은 모든 스파우트 작업이 전체적으로 와일드 카드와 일치하는 모든 주제의 모든 메시지를 소비한다는 것입니다. 각 메시지는 단일

0열

1답변

Storm-zookeeper 트랜잭션 로그 extremlly large

내 Storm 클러스터 (4 기계)에 ZooKeeper 클러스터 (3mchines)를 사용하고 있습니다. 문제는 폭풍우에 배치 된 토폴로지 때문에 사육사 트랜잭션 로그가 극단적으로 커져서 사육사 책상이 가득 차게되고 그 로그가 여러 파일로 분할되지 않는 것이 이상하다는 것입니다. 모든 사육사 기계에서 하나의 큰 거래 파일! 내 사육사 구성에서 자동 완성 기

0열

1답변

log4j 종속성으로 인해 Storm 서버에서 실행중인 Elastic 5.0 클라이언트 문제

최근에 우리는 elastic 5.0으로 업그레이드했습니다. Elastic 5.0의 Java 클라이언트는 log4j 2.6에 대한 의존성이 매우 큽니다. 스톰 서버 (버전 1.0.2)는 이전 버전 인 log4J를 사용하며 모두 유선 종속성을가집니다. 다음은 서버에 배포하려고 할 때 발생하는 오류이며 'PreBuiltTransportClient'를 인스턴스화

0열

1답변

파이썬 볼트에서 아파치 스톰 호출 함수

나는 다른 파이썬 모듈로부터 함수를 호출하기 만하면되는 간단한 스톰 볼트를 가지고있다. 함수 안에 print 문이있는 메소드를 호출하기 전까지는 모든 것이 작동합니다. 그래서 내 볼트 : import storm from pipeline import module as m class ExampleBolt(storm.BasicBolt): def

0열

3답변

사육사 또는 독립 기계에서 사육사를 운영해야합니까?

우리는 등 SOLR, 스톰, 카프카, HBase와 같은 사육사를 사용하는 소프트웨어의 여러 종류가 사육사 클러스터 (1 개 이상의 노드)를 설치하는 2 개 가지 옵션이 있습니다 : 포함 된 클러스터은 : 다른 소프트웨어가 설치된 것과 동일한 컴퓨터에 ZK를 설치하십시오. 외부 클러스터 : 사육자를 돌볼 수있는 매우 강력하지만 헌신적 인 사육 기계가 있습니다

4열

1답변

스트림 처리의 비 결정적 함수

StreamScope와 같은 일부 시스템에서는 함수가 결정적이어야하며 (처리되는 순서와 마찬가지로) 함수가 스트림에있을 때 각 메시지의 시퀀스 번호가 있기 때문입니다. 실패의 경우,이 시퀀스 번호는 이벤트가 다시 계산되어야하는지 (스트림에 의해 지속 되었기 때문에) 재전송 노드가 동일한 이벤트를 두 번 계산하지 않도록 결정하는 데 사용됩니다. Flink,

0열

1답변

복잡한 이벤트 처리 - 스트림 처리

저는 Esper가 Storm과 협력하는 방법을 배우려고합니다. Esper (테이블, 배열 등)가 데이터를 저장하는 위치를 찾고 싶기 때문에 Esper의 소스 코드를 살펴보고 있습니다. 예를 들어 esper가 튜플 스트림을 받고 이벤트 유형이 선언되면 Esper (소스 코드)가이 데이터를 저장하는 방법 쿼리가 실행될 때 데이터 결과가 어떻게 저장 되는가?이

1열

1답변

실제 클러스터 환경에서 Storm Bolts/Spout에서 Global Static 변수를 사용할 수 있습니까?

토폴로지 클래스에 토폴로지를 제출하는 주요 방법 인 Spout1 -> Bolt1, Spout2 -> Bolt2가있는 Storm 프로젝트가 있습니다. static 변수 -> List of Strings를 가진 또 다른 final 유틸리티 클래스가 있습니다. 이제 Bolt1은이 정적 목록을 사용하여 내용을 출력합니다. Bolt2는 목록에 String을 추가합니

1열

1답변

Apache Storm에서 시뮬레이트 된 시간을 사용하여 Java unit test를 작성하는 방법은 무엇입니까?

매분마다 집계를 계산하는 스톰 토폴로지가 있습니다. 자바 단위 테스트로 응용 프로그램을 다루고 싶습니다만 일부 Java 단위 테스트의 작동 예제를 찾을 수 없습니다. 시간의 변화를 시뮬레이트하고 토폴로지 출력을 가져 와서 테스트해야합니다.

0열

1답변

Intellij IDEA maven : "backtype"기호를 해결할 수 없습니다.

kafka의 입력으로 폭풍우에 Wordcount를 쓰고 있습니다. 내가 IDEA에서 프로젝트를 수행하는 동안, 필자는 필요한 모든 클래스 (실제로 대부분의 클래스)를 다운로드하지 못했습니다. pom.xml 파일은 <?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/P