apache-storm

10열

1답변

here : Storm은 처음부터 여러 언어와 호환되도록 설계되었습니다. Nimbus는 Thrift 서비스이며 토폴로지는 Thrift 구조로 정의됩니다. Thrift를 사용하면 Storm을 모든 언어에서 사용할 수 있습니다. Java에서 생성 된 토폴로지는 토폴로지 (스파우트, 볼트, ComponentCommon)를 Thrift 데이터 유형으로 직렬화하여

2열

1답변

폭풍 토폴로지를 실행할 때 InvalidClassException 로컬 클래스가 호환되지 않음

로컬 모드에서 실행할 때 단일 토폴로지를 실행하는 폭풍우 애플리케이션이 정상적으로 작동하지만 분산 환경에서 실행할 때 이러한 예외는 작업자 로그에서 발생합니다. 동일한 예외이지만 2 개의 다른 클래스를 참조합니다. java.lang.RuntimeException: java.io.InvalidClassException: storm.trident.topolog

6열

2답변

다른 원격 클러스터에 토폴로지를 배포 하시겠습니까?

폭풍 (storm-project.net)에 대한 토폴로지를 개발 중입니다. 2 개의 원격 클러스터가 있습니다 : 스테이징 및 프로덕션. 다른 원격 클러스터 인 production.storm.yaml 및 staging.storm.yaml을 가리키는 두 개의 storm.yaml 파일 (코드를 작성한 랩톱)이 있습니다. 안타깝게도 "storm jar"명령을 통해

2열

1답변

특정 사육사 노드가 실패하면 폭풍이 죽습니다.

나는 후각 서버와 3 개의 사육사 노드가 있습니다. 내 storm.yaml 파일은 다음과 같다 : storm.zookeeper.servers: - "server1" - "server2" - "server3" nimbus.host: "nimbus-server" storm.local.dir: "/var/storm" 내 zoo.cfg 모두가 같이

6열

1답변

복잡한 이벤트 처리

시스템으로 들어오는 개별 이벤트 스트림이 있고 각 이벤트의 내용을 기반으로 규칙을 적용해야합니다. 또한 이러한 스트림 이벤트에 복잡한 이벤트 처리를 적용하려고합니다. 제약 조건 1.이 규칙은 사용자가 입력하며 동적으로 변경됩니다. 2. 규칙이 적용될 때마다 시스템을 다시 시작하고 싶지 않습니다. 3. HA 4 만 성숙 오픈 소스 솔루션 이 단일 할 것 2.

0열

1답변

스톰 : Nginx 또는 Maven 또는 Zookeeper

데이터 스트리밍에 Twitter Storm을 사용하는 것이 처음이지만 예제를 실행할 때 몇 가지 문제가 있습니다. 사육사를 사용하는 예제가 있으므로 Maven과 Nginx를 사용하는 예제도 있습니다. 그 당시에도 2 명이 합쳐졌습니다. 누구든지 그 중 한두 가지를 사용해야 할 때 내 마음을 분명히 할 수 있습니까?

1열

1답변

Storm에서 "Warning : Field 'xxx'에 기본값이 없음"을 피하는 방법은 무엇입니까?

Storm에서 벗어나 경고 메시지를 표시하지 않는 방법이 있는지 궁금합니다. 이 필드를 처리하는 MySQL의 삽입 트리거가 있으며 예상대로 모든 기능이 작동하므로이 불필요한 정보를 제거하려고합니다. 기본값을 None으로 설정하려고했으나 필드가 null을 허용하지 않으므로 오류가 발생합니다. 그러면 경고를 어떻게 없앨까요?

3열

1답변

스톰 토폴로지에서 선형 볼트로 단일 볼트를 교체 할 때의 차이

내 스톰 토폴로지에서 큰 프로그램 논리를 단일 볼트로 유지하려고합니다. 이제 큰 프로그램 논리를 선형으로 배열 된 작은 볼트로 나누었습니다. 그것의 성능에 어떤 차이가 있습니까? 의견의 기술을 바탕으로

1열

1답변

내부 버퍼링으로 인해 폭풍에 메시지를 수집해야합니까?

이 기사에서 Understanding the Internal Message Buffers of Storm 폭풍은 내부 버퍼링을 수행한다고 언급했습니다. 이제 여러 계층 (볼트)이있는 내 폭풍 토폴로지에 수많은 이벤트가 발생할 것입니다. 첫 번째 레이어는 들어오는 모든 이벤트를 무작위로 "소화"하고, 들어오는 각 이벤트마다 다음 이벤트 (Bolt to Bol

2열

1답변

redis/webdis & storm, http 게시글로 게시

처음 약간의 설명; 시스템이있어 SystemA라고 부르면 뭔가 잘못되었을 때 지정한 URL에 http 게시물을 보내도록 구성 할 수 있지만 요청 본문은 직접 수정할 수 없습니다. 제 목표는 redis pubsub 대기열을 통해 게시물 요청의 본문을 폭풍우 치는 소리로 유도하는 것입니다. url: http://127.0.0.1:7379/ body:/PUBL