apache-storm

0열

1답변

스톰 UI 오류 : org.apache.storm.utils.NimbusLeaderNotFoundException : 시드 호스트 [localhost]에서 리더 후광을 찾을 수 없음

m 윈도우 7 64 비트 시스템에 apache storm을 설정하려고합니다. 내 구성 tickTime=2000 initLimit=5 syncLimit=2 dataDir=C:/Server-Local/zookeeper-3.4.9/data clientPort=2181 이 storm.yaml storm.zookeeper.servers: - "l

0열

1답변

이 STORM_HOME

에 디렉토리를 기록, 평소에도 올바른 디렉토리가 이기 때문에 나는 로그 디렉토리를 찾을 수 없습니다하지만 실제로 나는 디렉토리가 얻을 본 것처럼 로그 디렉토리가 사라집니다. 로그 디렉토리가 사라진 이유가 궁금합니다. 그리고 나는 감독관으로서 폭풍우를 시작합니다. 결과는 여전히 그렇습니다.

0열

1답변

Storm 1.0.2 데이터가 전송되지 않을 때의 hdfs-bolt acking 튜플

나는 Kafka Spout에서 JSON 데이터를 가져 와서 두 개의 볼트를 처리 한 다음 hdfs- 볼트. Storm 0.9.6과 Kafka 0.8.2.1 및 Hadoop 2.5.0을 사용하여 완벽하게 작동했습니다. 필자가 구현 한 프로덕션 시스템은 Storm 1.0.2, Kakfa 0.10.1.0 및 Hadoop 2.6.0으로 도구를 업데이트합니다. 위의

0열

1답변

spout은 볼트 인스턴스의 서브 세트에 튜플을 보냅니다.

방금 폭풍으로 시작합니다. 나는 주둥이 (1 집행자)와 볼트 (4 집행자)의 간단한 토폴로지를 가지고 있습니다. 스파우트와 볼트는 "shuffleGrouping"을 통해 연결됩니다. 내가 볼 수있는 것으로부터 스파우트는 튜토리얼을 볼트 실행자의 서브 세트 (스파우트와 동일한 호스트에서 실행중인 서브넷)로 보냅니다. 예상 되나요? 거기에 상관없이 모든 볼

0열

3답변

스톰이 폭풍우 클러스터 모드에서 데이터를 읽거나 내보내지 않습니다.

클러스터 모드뿐만 아니라 로컬 모드에서도 apache storm 1.0.0을 사용하고 있습니다. 스파우트의 경우 kafka 주제 (kafka 2.11-0.8.2.1을 사용 중입니다)에서 데이터를 읽습니다. 스파우트는 kafka 주제에서 데이터를 읽는 중이고 로컬 모드에서 스톰을 사용할 때 데이터를 방출하지만 클러스터 모드에서 스톰을 실행할 때 스톰 스파우트

0열

1답변

터플을 방출해서는 안되는 Apache 폭풍우 마지막 볼트?

가정하면 우리는, 즉 데이터베이스의 정보를 지속, 다음 토폴로지 spout A -> bolt B -> bolt C -> bolt E 및 볼트 E 마지막 한 어떤 튜플을 방출하기 때문에 아무 필요가 없다. 어떻게 이러한 솔루션을 구현하기 위해, 내가 더 output_fields이 정의 경우 - 나는 예외 Exception in thread "main" j

0열

1답변

Apache Storm의 TupleWindow 시작/종료 시간

Apache Storm의 CDR (Call Detail Record) 데이터에서 프로파일 링 애플리케이션을 개발했습니다. 응용 프로그램의 주된 목적은 호출자 TotalCallCount 및 TotalCallDuration을 지정된 시간 블록 (모든 창에서) 중에 추출하는 것입니다. profilling에 대해서는 SlidingWindow 기술을 사용하고 싶습니

0열

1답변

BaseStatefulBolt (Storm Core) 대 StateFactory (Storm Trident)

폭풍 사용에 대해 혼란스러워합니다. 스트리밍 된 데이터를 사용하여 데이터 소스의 상태를 측정하려고합니다. 상태는 일부 필드의 결합으로 계산되며,이 필드는 다른 시간 간격을 얻을 수 있습니다. 그래서 데이터 소스의 상태를 측정하기 위해 필드를 저장해야합니다. BaseStatefulBolt를 사용할 수 있습니까? 아니면 유일한 솔루션은이 cenario에 대한

0열

2답변

KafkaSpout 튜플 재생에서 null 포인터 예외가 발생했습니다.

storm-kafka-client 1.0.3과 함께 1.0.1 및 Kafka 0.10.0.0을 사용하고 있습니다. 내가 가지고있는 코드 설정을 찾으십시오. kafkaConsumerProps.put(KafkaSpoutConfig.Consumer.KEY_DESERIALIZER, "org.apache.kafka.common.serialization.ByteArr

1열

1답변

Apache Storm Supervisor Error : 메인 클래스 org.apache.storm.daemon.supervisor를 찾을 수 없거나로드 할 수 없습니다.

Windows 7 워크 스테이션에서 스톰 관리자를 시작하려고 다음과 같은 오류가 발생합니다. 오류 : 메인 클래스를 찾지 못했습니다 org.apache.storm.daemon.supervisor. 아무런 오류없이 성공적으로 nimbus를 시작할 수있었습니다. P.S : 처음에는 Nimbus에서도 같은 문제가있었습니다. 그런 다음 Apache Storm Ni