apache-storm

2열

1답변

스테이트 풀 스트리밍 프로세스와 스테이트리스 스트리밍 프로세스의 차이점을 알고 있습니다. 나는 폭풍이 무국적이며, 삼지창은 상태가 좋다는 것을 읽었습니다. 또한 Hadoop (일괄 처리 용)은 상태 저장이며 Spark은 상태 저장 작업을 계산할 수 있다고 읽었습니다. 누군가이 각각에 대해 명확하게 설명 할 수 있습니까? 구체적으로, 상태 저장과 상태 비 저

0열

1답변

내가 르네 S와 토폴로지를

볼트 하나, 3 볼트에서 실패()의 경우 스톰의 재생에 의한 이벤트의 중복을 처리하는 방법 - A는, B, C. 볼트 A가 읽 Spout S. Bolt A는 데이터를 볼트 B 및 C (일부 필터 기준)로 분할합니다. 볼트 B와 C에는 각각 데이터 싱크가 있습니다. 폭풍의 고정을 사용하고 볼트 A에 튜플을 고정한 다음 나중에 볼트 B에 성공했지만 볼트 C가

1열

1답변

backtype.storm 및 org.apache.storm 및 com.twitter.heron 패키지의 클래스 간 차이점

아파치 왜가리 용 사용자 정의 스케줄러를 작성하고 싶습니다. 소스 코드를 조금 깊숙이 살펴보고 싶습니다. 헤론 소스 코드에는 유사한 클래스를 가진 몇 개의 패키지가 있다는 것을 알았습니다. 예를 들어, 대부분의 클래스는 backtype.storm & org.apache.storm과 매우 유사합니다 (내부 코드가 완전히 같음). 이 두 패키지 사이에는 유사한

0열

1답변

볼트가 특정 스파우트 스트림에서 소비 한 튜플을 확인하지 못한 경우 어떻게됩니까?

두 개의 스트림 (stream1 & stream2)에 주제의 메시지를 내보내는 스파우트가 있고 두 개의 볼트가이 스트림 (bolt1 -> stream1, bolt2 -> stream2)에서 메시지를 소비합니다. 이제 볼트 2가 실패하면 폭풍의 새로운 소비자 API (apache-storm-1.0.2)에 따르면 numFail> maxRetry 인 경우 터플이

0열

1답변

Apache Storm에서 런타임에 볼트 프로세스 편집

내 프로젝트는 오브젝트 데이터를 폭풍우 치면서 그래픽 응용 프로그램으로 스트리밍합니다. 이러한 객체의 모양은 폭풍 토폴로지의 볼트에 의해 할당 된 변수에 따라 다릅니다. 내 질문은 그것이 개체 데이터에 연결하는 변수를 변경하는 메시지를 보내서 볼트 프로세스를 업데이트 할 수 있는지 여부입니다. 예를 들어, 특정 번호 위에 매개 변수 x가있는 객체를 파란색이

0열

1답변

는 : 하나 개의 볼트 작업에 코드의 라인을 실행하는 방법

나는 주둥이와 볼트 (numTasks은 = 16)와 폭풍 토폴로지가 있습니다. 볼트의 한 작업에서만 코드의 특정 부분 (한 번만)을 실행하고 싶습니다. 어떻게해야합니까? 나는 볼트의 준비 방법으로 그 일을 생각,하지만 난 미리 볼트에 할당됩니다 작업 ID를 알 수 없습니다. 은 가능한 그 사육사 이상에서 볼트의 준비 방법은 현재 작업 ID로 선거 지도자와

5열

2답변

봄 부팅 동네 짱 항아리 포장 클래스 대신 BOOT-INF/클래스

안녕 봄 부팅 전문가의 뿌리입니다. 그러나 Storm은 "spring-boot-maven-plugin"을 사용하여 패키징 할 때 패키지 된 응용 프로그램 파일이 "BOOT-INF/classes"아래에있는 동안 jarm의 루트에있는 모든 클래스 파일을 기대하고 있습니다. 내 앱 클래스를 "BOOT-INF/classes"대신 루트에 직접 패키지화 할 수있는 방

0열

1답변

기본이 아닌 java 버전을 스톰으로 타겟팅

내 폭풍우 클러스터 노드에는 2 개의 Java 버전이 설치되어 있으며 기본 버전을 변경할 수 없습니다. 스톰이 기본이 아닌 버전으로 실행하도록 말할 수 있습니까?

0열

1답변

Kafka Storm과 Java의 통합. kafka.api.OffsetRequest.DefaultClientId() Ljava/lang/String; 오류

나는 카프카와 폭풍을 처음 사용합니다. 나는 Kafka와 폭풍을 통합하는 자바 예제를 구현하려고 시도했다. 온라인에서 예제를 발견했습니다. Eclipse IDE에서 Java 프로그램을 실행하려고합니다. 나는 Maven을 사용하지 않는다. 나는 외부 항아리로 storm-kafka-0.10.0.jar, kafka-0.6.jar, scala-library-2.1

1열

1답변

스톰 1.0.2에서 kafka-spout은 토폴로지를 다시 시작할 때마다 동일한 데이터를 반복적으로 사용합니다.

현재 폭풍 버전 프로젝트를 개발 중입니다. 0.9.6-> 1.0.2 내 스파우트가 사용 된 경우에도 최신 오프셋에서 읽기를 시작하지 않았습니다. SpoutConfig 생성자에서 동일한 spout ID. 오, 나는 사육자 데이터를 삭제하지 않았으며, 단지 폭풍 데이터를 삭제했습니다. 내 프로젝트 구성 및 소스를 과 같이 변경했습니다. 1. pom.xml에서