apache-storm

1열

2답변

일부 데이터 스트림을 처리하기 위해 폭풍우를 사용하고 있습니다. 처음에 나는 내가 에스퍼 볼트에 사용되는 문장을 찾을 수 xml 파일을 읽습니다. 곧 내 토폴로지를 정의하고 클러스터에서 실행합니다. 이제 볼트에서 명령문을 변경하려면 xml을 수정하고 클러스터를 중지 한 다음 처음부터 다시 시작해야합니다. 내 XML을 검사 할 때 클러스터가 진행되는 동안 새

4열

1답변

휴식 API 엔드 포인트를 스톰 스파우트로 설정하는 방법은 무엇입니까?

나는 예를 들어 요청이 엔드 포인트 URL (예 : http://example.com/search?q=test)에 만들어 질 때마다 폭풍 토총으로 나머지 API 엔드 포인트를 설정하고 싶습니다. 그런 다음 특정 볼트로 폭풍 토폴로지를 실행하고 싶습니다. 문제는 모든 시간 요청이 만들어진 것이 아니기 때문에 특정 간격으로 스파우트의 nextTuple() 메서

0열

1답변

StormSpout으로 데이터를 읽을 수 없습니다.

KafkaSpout을 사용하여 Kafka 대기열에서 메시지를 읽으려고합니다. 2 [Thread-10-kafka-storm-spout] ERROR util:0 - Async loop died! java.lang.NoSuchMethodError: scala.Predef$.augmentString(Ljava/lang/String;)Ljava/lang/Strin

1열

1답변

ZeroMQ/JZMQ가없는 Apache 스톰 설치

다중 클러스터 폭풍 시스템을 설정하려고합니다. 나는 이것에 대한 단계 가이드로 여러 타사 단계를 발견했습니다. Nimbus 및 Supervisor/Slave 노드의 요구 사항은 모두 Java, Python, ZeroMQ 2.1.7 및 JZMQ입니다. 그러나 공식 Apache Storm 웹 사이트에서 Nimbus 및 Supervisor 노드에 대한 유일한 요

1열

1답변

명령 프롬프트를 통해 스톰 토폴로지 클래스를 실행하는 방법은 무엇입니까?

안녕하세요, 그것의 주요 방법으로 단일 토폴로지 클래스가 있습니다. zookeeper를 시작하고 eclispe에서 마우스 오른쪽 버튼을 눌러 Java 응용 프로그램으로 실행합니다. 하지만 난 그것을 시도 배치 파일을 통해 실행할 수 있도록 노력하고 있습니다 java -classpath jar-with-classes-and-dependency.jar com.

1열

1답변

보안을 위해 storm UI의 인증을 활성화하는 방법은 무엇입니까?

최근에 분산 실시간 컴퓨팅 시스템 "Storm"을 설치합니다. 스톰 UI를 활성화하면 누구나 폭풍우 http://xxxxx:8080에 액세스 할 수 있으며 내 토폴로지를 죽일 수 있습니다. 인증을 활성화하는 방법은 무엇입니까?

1열

2답변

monit으로 아파치 스톰 모니터링하기

Monit의 도움을 받아 수퍼바이저 시스템에서 스톰 토폴로지 프로세스를 모니터하는 방법을 찾으려고합니다. 누군가가 그렇게 할 수 있었는지 궁금 해서요. 또는 그런 일을 할 수있는 권장 프리웨어/오픈 소스 도구가 있는지 궁금합니다. 기본적으로 수퍼바이저의 다른 토폴로지 프로세스의 CPU/메모리 사용량을 모니터링하고 현재 모니터 자체에 대해 monit을 사용하

1열

2답변

stormconf.ser does not exist 작업자에게 오류가 발생했습니다.

나는 2 노드 폭풍우 클러스터와 1 개의 zk가 있습니다. 다음 오류로 인해 작업자 중 하나가 사망합니다. stormconf.ser 파일이 삭제되는 이유에 대해 알고있는 사람이 있습니까? 나는 0.9.2 폭풍과 폭풍의 이전 릴리스에서 문제가 알려져 3.4.6 ZK 버전을 o.a.c.f.s.ConnectionStateManager [INFO] State ch

1열

2답변

폭풍 테스트 볼트

저는 아파치 스톰을 처음 접했고 실제로 완전한 토폴로지를 구축하지 않고 볼트 테스트 방법을 찾고있었습니다. 모의 테스트를 피하고 싶었습니다. 대신 OutputCollector 객체에서 출력을 내보내는 볼트 메서드를 호출하려고했습니다. 하지만 OutputCollector 개체에서 데이터를 가져 오는 메서드를 찾고 메서드를 찾지 못했습니다. OutputColl

0열

1답변

하늘빛 Eventhub 아파치 스톰 문제

나는 this 아파치 스톰으로 eventhub를 시도하는 기사를 따랐다. 그러나 스톰 토폴로지를 실행할 때 잠시 동안 이벤트를 받고 나서 수신을 중단했다. 그래서 프로그램을 다시 시작한 다음 남은 메시지를 받았습니다. 1 분 후에 프로그램을 실행할 때마다 eventhub에서 수신 할 수 없습니다. 문제의 가능성을 도와주세요. Storm 또는 Zookeepe