apache-storm

1열

1답변

스트림 처리 인프라를 처음으로 구현하는 경우 독이 storm 1.0.1, kafka 0.9.0 및 Clojure 1.5입니다. 이제 메시징 시스템 (RabbitMQ)에 대한 배경 지식이 있고 몇 가지 이유로 좋아했습니다. 나는 소비자를 시작하고 메시지가 소비되지 않은 알고있는 경우 영구 메시지 상태는 유지됩니다 니스 프론트 엔드 웹 포털을 설치 및 유지 관

1열

1답변

fieldsgrouping에서 여러 필드를 사용하면 어떻게됩니까? <em></em> fieldsgrouping</p> <pre><code>{"first_name", "last_name"} </code></pre> <p>우리가 사용하는 두 속성에 분할 :

우리는 다음과 같은 두 가지 속성을 가진 이벤트와 이벤트 스트림을 가정 처리 볼트는 두 가지 작업에 의해 병렬화 .fieldsgrouping{"spout", new Fields("first_name", "last_name")} 및 다음 이벤트가 지정된 순서대로 스트림에 입력됩니다. 1: {"foo", "foo"} 2: {"bar", "bar"} 3:

0열

1답변

KafkaSpouts를 Apache Storm 토폴로지에 동적으로 추가/제거 할 수 있습니까?

여러 카프카 항목의 메시지를 받아들이는 Apache Storm 토폴로지가 있습니다. 현재 "다중"은 "2"와 동일합니다. 다음과 같이 I는 현재 열심히 모두 내 토폴로지 클래스에 코딩 및 코딩 한 듣는 두 KafkaSpouts을 가지고 : - KafkaSpouts의 수는 시간이 지남에 따라 증가하지만 builder.setSpout(SPOUT_ONE_ID,

0열

1답변

스톰 토폴로지의 모든 스레드에서 변수 동기화

Kafka 대기열에서 Cassandra DB로 일부 데이터를 쓰는 스톰 토폴로지가 있습니다. 이 프로그램은 다중 스레드 프로그램입니다. 카산드라의 dB의 삽입을 용이하게하기 위해, 나는 내 DBUtils로이 있습니다 public DBUtils() { if(session == null) { session = CassandraUtil.get

0열

1답변

영향

내가 최근에 아파치 스톰을 사용하기 시작했다. 지금은 한 번에 더 많은 병렬 요청 처리가 가능하도록 내 애플리케이션 중 하나에 대한 성능 테스트 및 튜닝 (NoSQL 데이터베이스에서 데이터를 가져 와서 형식을 지정하고 요청자가 사용할 수 있도록 JMS 큐에 게시)에 중점을 둡니다. 나는 no를 바꾸는 관점에서 토폴로지를 조정할 수있었습니다. MAX_SPEN

2열

1답변

폭풍우, 지정된 볼트 하나의 실행자 수를 1로 설정하면 볼트가 항상 한 고정 호스트에서 실행됩니까?

위와 같이 하나의 볼트 만 하나의 호스트에서만 실행하고 싶습니다. 따라서 집행자 번호를 1로 설정하면 목표를 달성 할 수 있습니까?

0열

1답변

Apache Storm에서 노드에서 실행중인 작업을 결정하는 방법

같은 노드에서 실행중인 다른 볼트에 한 볼트의 방출을 전파하는 CustomGrouping을 작성하고 싶습니다. localOrShuffleGrouping은 동일한 프로세스 내에서 튜플을 유지하려고 시도함으로써 부분적으로이를 달성합니다. 한 단계 더 나아가 기계 수준에서 경계를 만들고 싶습니다. 주된 목적은 네트워크 대기 시간을 줄여 대역폭을 제한하지 않음으로

0열

1답변

Apache Strom은 임의의 시간 간격 후에 통계를 재설정합니다.

토폴로지가 하나의 볼트와 하나의 주둥이가 있습니다. 잘 작동하지만 때로는 모든 통계가 사라지고 0부터 계산되기 시작합니다. 감독관, 후광 또는 다른 어떤 것도 다시 시작하지 않습니다. 그 원인은 무엇일까요?

2열

1답변

yahoo 스트리밍 벤치 마크에서 STORM_TEST를 실행하려고 할 때 오류가 발생했습니다

yahoo 스트리밍 벤치 마크를 사용하여 STORM을 테스트하려고하면 이러한 오류가 발생합니다. 나는 ZooKeeper "zoo.cfg"파일과 kafka "server.properties"에서 기본 포트 2181 대신 2080 포트를 변경하려고 시도했습니다. 여전히 동일한 오류가 발생합니다. 어떤 도움이라도 대단히 감사 할 것입니다. 미리 감사드립니다. :

0열

1답변

폭풍을 사용할 때 하나의 서버가 고장난 경우 (예 : 종료) 토폴로지가 호스트에서 처리 된 터플을 다시 처리합니다

예를 들어 튜플 A가 이제 서버 B에서 처리되고 있습니다. 갑자기 서버 B가 내 미친 동료. 토폴로지 프로세스가 다른 서버에서 A를 다시 튜플 링합니까?