apache-storm

0열

1답변

1 개의 후광 및 4 개의 수퍼바이저 노드가있는 Storm v1.0.1 클러스터를 시작합니다. 나는 2 개의 사육사 노드를 가지고있다. 카프카에서 소비해야하는 샘플 토폴로지를 시작하려고합니다. 그러나 토폴로지가 제출 된 후 nimbus와 관리자 로그를 검사 할 때, 나는 근로자가 출동하지 않는다는 것을 발견했다. storm.yaml storm.zookeep

0열

1답변

스톰 크롤러를 사용하여 크롤링

스톰 크롤러를 구현하여 데이터를 크롤링하려고합니다. 우리는 URL에서 하위 링크를 찾을 수 있었지만 그 하위 링크의 컨텐츠를 얻고 싶습니다. 나는 그것을 얻는 방법을 안내 할 많은 자원을 찾을 수 없었다? 이와 관련하여 유용한 링크/웹 사이트가 도움이 될 것입니다. 감사.

1열

2답변

Storm-Kafka : java.lang.NoClassDefFoundError : com/google/common/base/Strings

storm-core 1.0.2 및 kafka-spout 1.0.2를 사용하여 폭풍우의 LocalCluster를 실행하려고합니다. 내 치어 파일 I 로컬 폭풍 클러스터를 실행하려면 다음 명령을 사용 <dependencies>  <dependency> <groupId>org.apache.

0열

1답변

Apache Storm 토폴로지에서 스파우트와 볼트 사이에 내부 큐가 있습니까? 위해

이 으로 특정 RabbitMQ 메시지 브로커 구현을 준수하기 위해서는 주둥이 가 방송 메시지를 사용하고 가능한 한 빨리로 인정 중요한입니다. Message Broker 인스턴스의 사양은 처리 시간이 느린 경우 수신 확인을 지연시키지 않으려면 소비자가 메모리 대기열을 구현해야한다는 사실을 강조합니다. 과 같은 내재적 큐가 있습니까? ? 볼트 내에서 메모리 내

2열

1답변

Apache Storm : OutputCollector.fail() 메소드는 어떤 기능을합니까?

BaseRichBolt를 사용하여, 그것은 밖으로 그래서 한 번처럼 행동 튜플을 재전송하게 하는가 _collector.fail(tuple) 및 _collector.ack(tuple) 의 차이점은 무엇입니까? 아니면 그냥 튜플을 버리지 않습니다. 그렇다면 fail 방식과 ack 방식의 차이점은 무엇입니까?

0열

1답변

스파크 또는 스톰 (Trident)

시스템의 구성 요소를 확장하고 Storm (Trident)과 Spark간에 더 좋은 방법이되어야한다고 생각합니다. 그래서 우리는 redis 클러스터 내부에 저장된 최대 백만 개의 이벤트를 포함 할 수있는 2 개의 큰 세트를 가지고 있습니다. S1과 S2를 말하십시오. 이제 우리는 메시징 큐 (Kafka)에서 메시지를 읽고 S1과 S2 (기본적으로 ** S1

0열

1답변

Apache Storm 호환성

Apache Storm 1.0.2와 Zookeeper 3.4.9를 사용하여 Apache Storm Cluster를 설정하려고했습니다. 모든 것은 정상적으로 작동했지만 아파치 사모아 (Apache for Samoa)는 클러스터 폭탄을 사용하기 위해 Apache 폭풍 < 1.0.0 버전과 만 호환됩니다. 따라서 모든 Apache Storm 노드를 Apache

0열

2답변

오류 : JNI 오류가 발생했습니다. 설치를 확인하고 다시 시도하십시오 .NoClassDefFound 오류 : DRPCExecutionException

폭풍 토폴로지 (v1.0.2)에 연결하려고 할 때 DRPC 클라이언트 요청이 다음과 같은 오류가 발생합니다 : ERROR: A JNI error has occurred, please check your installation and try again. exception in thread "main" java.lang.NoClassDefFoundError:o

1열

2답변

kryo serialization over storm

아파치 스톰 (원격 클러스터에 배포 됨)보다 복잡한 객체 (opencv : Mat)를 직렬화해야합니다. 누구든지 나에게 좋은 튜토리얼 맞춤 kryo 직렬화를 제안하거나 이것을 수행하는 방법에 대한 해결책을 제안 할 수 있습니까? 미리 감사드립니다.

1열

1답변

Apache Storm Spout에서 파이썬으로 파일 열기

Apache Storm Spout을 파일별로 한 줄씩 읽으려고합니다. 이 진술을 쓰려고했지만 작동하지 않았습니다. 그것은 나를 첫 번째 줄은 매번 반복했다 : class SimSpout(storm.Spout): # Not much to do here for such a basic spout def initialize(self, conf,