apache-storm

0열

1답변

저는 아파치 스톰 (Apache Storm)의 초보자이며 터플의 순서가 스트림에서 보증되는지 궁금합니다. 이 게시물을 바로 가져 오면 Processing records in order in Storm 볼트/주둥이와 다른 볼트 사이의 순서가 보장됩니다. 타임 스탬프에 따라 정렬되고 일부 ID에 따라 필드 그룹화가있는 볼트가있는 Tuples를 방출하는 Kaff

0열

3답변

스톰 토폴로지 배포 시간 초과

Macbook Pro에 Apache Storm (1.0.2)을 설치하려고하지만 토폴로지를 배포하려고하면 시간 초과 문제가 발생합니다. 또한 UI는 동일한 예외를 스며 들었다. 내가 기본값을 사용하고 3491 [main] INFO o.a.s.StormSubmitter - Generated ZooKeeper secret payload for MD5-digest

0열

1답변

Apache 폭풍으로 비활성화 된 토폴로지로 인해 CPU 사용률이 높습니다.

비활성화 된 apache storm 토폴로지에 높은 CPU 사용량 문제가 있습니다. 아래 단계를 사용하여 문제를 신뢰할 수있게 다시 만들 수 있지만 정확한 원인이나 해결 방법을 아직 찾지 못했습니다. 환경은 1 개의 토폴로지가 실행중인 스톰 클러스터입니다 (토폴로지는 매우 간단하며 느낌표 예제 사용). 그것은 비활성입니다. 초기에는 정상적인 CPU 사용이

0열

1답변

"오류 : 찾거나 메인 클래스로드 할 수 없습니다"나는 자바 버전, CLASSPATH는 자바 경로와 속성> 실행/디버그 설정</p> <p>를 구축하지만이 문제를 해결할 수 있음을 확인

"폭풍 항아리"를 사용할 때 오류 오류 Could not find or load main class 이 문제를 해결하기 위해 어떤 정보가 필요합니까? 이 ... 나는 내가 그것을 수정해야한다고 생각 오류 및 컴퓨터 정보 #storm jar tims-0.0.1-SNAPSHOT.jar com.clunix.tims.TIMSTopology TIMSTopology

0열

1답변

스톰 토폴로지가 복수 log4j 파일로 인해 제출되지 않음

스톰 토폴로지 제출이 다중 log4j 오류로 인해 실패했습니다. 지역 일식에서는 작동합니다. 그러나 Storm 클러스터에서 토폴로지를 제출하면 토폴로지 제출이 실패합니다. 폭풍 버전 1.1.1 & kafka_2.9.2 (0.8.1.1)를 사용 중입니다. 어떻게 eclipse에서 maven을 통해 jars로부터 오는 log4j 파일을 찾을 수 있습니까?

0열

1답변

프로그래밍 방식으로 C# storm 토폴로지를 HDInsight에 배포하는 방법

패키지를 jar 파일로 사용하도록 프로그래밍 방식으로 폭풍 토폴로지를 HDInsight에 제출하는 유일한 방법은 무엇입니까? 아래 링크에 C# 파일을 배포하는 것을 언급하지만 수동 프로세스를 통해서만 가능합니다. 그렇지 않은 경우 프로그래밍 방식으로 C# 토폴로지를 HDInsight 클러스터에 배포하려면 어떻게해야합니까? UI를 사용하지 않고 Visual

0열

1답변

Apache Storm의 Scheduler와 Strategy의 차이점

Apache Storm을 연구 중입니다. 소스 코드 & & 개발자 설명서 & & JavaDoc & & Storm에 대한 유용한 블로그. 많은 질문이 나를 혼란스럽게 만들었습니다. 대부분의 문서와 블로그는 스톰 클러스터가 토폴로지를 작업자에게 할당 할 때 다른 스케줄러가 다른 할당 스타일을 유도한다고 전했다. 그러나 Storm이 토폴로지를 할당 할 때 Def

2열

2답변

최대 스파우트 용량

IoT 데이터에서 스트리밍 분석을 수행하기 위해 헤론을 사용하고 있습니다. 현재 아키텍처에서 병렬 처리 요소 1을 가진 스파우트가 하나만 있습니다. 스파링에서 내부적으로 사용하는 대기열에서 헤론이 보유 할 수있는 데이터 양에 대한 통계를 벤치마킹하려고합니다. 값을 전달하여 setMaxSpoutPending() 메서드를 사용하고 있습니다. 이 메소드에 전달하

0열

1답변

Kotlin : 필터링 된 (가능하면 비어 있고 하나의 요소 일 수도 있음) 목록

나는 이라는 시간 필드를 갖는 MyClass 유형의 값을 포함하는 튜플을 얻는 스톰 볼트가 있습니다. 볼트 끝 부분에서 처리가 처음부터 걸린 시간 (startTime으로 표시)을 기록하고 싶습니다. 그래서 나는 할 수 있었다 : override fun doExecute(input: Tuple): Boolean { ... // my processin

0열

1답변

스파우트에서 스톰 토폴로지를 죽임

스톰 토폴로지를 계속 실행하지 않으려는 유스 케이스가 있습니다. 대신 지정된 시간에 처리해야하는 입력 (10K +) 집합이 있으며 Spout은 이러한 입력을 지속적으로 내보내고 토폴로지의 나머지 볼트로 처리합니다. 일단 모든 입력이 처리되면, 내 스파우트의 nextTuple에서 방출 할 것이 없습니다. 우리는 토폴로지가 잠자기 상태가되어 매일 밤 12시에