apache-storm

0열

1답변

스파우트의 nextTuple 메소드를 초당 특정 횟수로 호출 할 수있는 방법이 있습니까?

0열

2답변

에 하나의 일괄 처리에서 여러 쿼리를 실행하는 방법 : 나는 큐 스파우트에서 카산드라에서 이러한 레코드를 생성 할 아파치 폭풍 볼트를 사용하고 create table experience.userstats (stream varchar, user varchar, computer varchar, experience varchar, amount int, prima

0열

1답변

내가 w 볼트에서 두 번 소비하면 어떻게 acker가 작동합니까?

내 토폴로지에는 기본 스트림에서 한 번 출력되는 boltA가 있습니다. 볼트 B와 C는 셔플 그룹을 사용하여이 볼트에 가입합니다. 이 시나리오에서 어떻게 작동합니까? B와 C가 터플을 두 배로 늘리지 않고, 그렇지 않은 상태로 두지 않을까요? 나는 이상한 행동 토폴로지에 대한 온 전성 검사를 요청합니다.

0열

1답변

Apache storm Trident - 토폴로지를 동적으로 생성

트라이던트에서 토폴로지를 동적으로 생성하는 방법이 있습니까? 아무도 예제를 제공해 줄 수 있습니까?

1열

1답변

스톰 트라이던트를 일괄 처리 튜플에 사용하는 방법은 무엇입니까?

나는 이전에 폭풍우를 사용 중이었고 더 많은 배치 기능이 필요했기 때문에 폭풍 속에서 배치 작업을 검색했습니다. 그리고 실시간으로 마이크로 일괄 처리를 수행하는 Trident를 발견했습니다. 그러나 어떻게 든 Trident가 마이크로 일괄 처리 (흐름, 일괄 처리 크기, 일괄 처리 간격)를 처리하여 내가 필요한 것을 실제로 처리하고 있음을 알 수 없습니다.

0열

1답변

여러 defaults.yaml 리소스를 찾았습니다. 스톰 항아리와 토폴로지 항아리를 번들로 묶어 두었을 것입니다.

그래서 지금 문제를 알고 있기 때문에 질문과 제목을 업데이트했습니다. 이것은 작업자 로그입니다.이 질문과 같은 질문이 많지만 (i) 어떤 솔루션이든 내가 할 수있는 모든 작업을 수행 할 수는 없습니다. 편집 : 링크에 언급 된 것과 같은 문제이지만 아래 답변에 언급 된 의 다른 원인이 있습니다. 이것은 작업자 로그입니다. 2016-06-23 00:10:56

0열

2답변

Apache Storm의 볼트를 통해 출력 필드 전달하기

내 볼트 (BaseBasicBolt를 확장)의 declareOutputFields 함수에서 이전 볼트 또는 주둥이로부터받은 동일한 필드를 선언하는 간단한 방법이 있습니까?

0열

1답변

임의의 창에 대한 폭풍 통계 컴퓨터

Apache Storm의 모든 창에 대한 통계는 어떻게 얻을 수 있습니까? 기본적으로 스톰은 600, 10800, 86400 초 동안 statictics를가집니다. 지난 5 분간의 정보를 알고 싶습니다.

0열

1답변

토폴로지 시작시 틱플 튜플을 보내는 방법은 무엇입니까?

폭풍의 진드기 튜플은 'emitFrequency'초마다 실행됩니다. 정확하게 이해하면 'emitFrequency'초 후에 해고됩니다. 토폴로지 시작시 틱 튜플을 발생시키는 방법이 있습니까?

2열

2답변

Apache Storm : 다른 볼트로 방출되는 가변 객체

몇 주 후, 우리는 우리 프로젝트에서 Storm을 사용하고 있습니다. 오늘, 우리는 매우 이상한 행동을 발견했습니다. 의 우리는 다음과 같은 토폴로지를 가정 해 봅시다 : 그래서, 우리는 사용자 정의 자바 객체를 방출하는 SpoutA이 SpoutA ---> BoltB ---> BoltC 두 개의 서로 다른 볼트에 (의이 메시지를 부르 자).