apache-storm

4열

3답변

저는 현재 토폴로지를 개발하기 위해 Windows 기반 Netbeans에서 작업하고 있습니다. 내가 로컬 모드에서 배포하는 경우 : LocalCluster cluster = new LocalCluster(); cluster.submitTopology("word-count", conf, builder.createTopology()); 모든 것이 잘 작동하지만

7열

0답변

Log4j 및 Storm Framework를 사용하여 파일에 로그를 쓰는 방법은 무엇입니까?

폭풍에 log4j를 사용하여 파일에 로깅 할 때 약간의 문제가 있습니다. 내 주요 방법, 즉 내 토폴로지를 제출하기 전에 나는 일부 로그 문을 작성하고 사용하여 로거를 구성 : PropertyConfigurator.configure(myLog4jProperties) 지금은 이클립스 내 실행 항아리를 사용하여 내 토폴로지를 실행할 때 - 정상적으로 잘 작

-1열

1답변

Python, 프로그램 타이밍 : 폭풍이 얼마나 멀어?

나는 천둥과 플래시를 3으로 나눈 초를 사용하여 "얼마나 먼 폭풍인가"프로그램을 진행하고있었습니다. 또한 340 * 1000 초가 더 정확하다고 들었지만이 질문의 요지는 아닙니다. from time import time print("Press enter when you see flash and then again when you hear thunder:"

1열

1답변

nimbus.task.timeout.secs 란 무엇입니까? 폭풍우입니다

무엇이 nimbus.task.timeout.secs은 폭풍우입니다. topology.message.timeout.secs과 다른 점.

2열

4답변

폭풍 - java.net.ConnectException : 연결이 거부되었습니다

나는 폭풍우 서버를 배치했지만 관리자를 시작할 때마다 다음과 같은 오류가 발생합니다. 2014-09-08 09:04:40 o.a.z.ClientCnxn [INFO] Opening socket connection to server localhost/127.0.0.1:2181. Will not attempt to authenticate using SASL (u

1열

1답변

클래스 경로가 여러 SLF4J 바인딩을 포함, 로그 백 클래식 log4j에 난 내 자바 프로젝트에 단위 테스트를 실행하려고하면 오류가 아래 점점

: : 이 SLF4J: Class path contains multiple SLF4J bindings. SLF4J: Found binding in [jar:file:/Users/me/.m2/repository/org/slf4j/slf4j-log4j12/1.5.8/slf4j-log4j12-1.5.8.jar!/org/slf4j/impl/StaticLogger

0열

1답변

Amazon EC2 인스턴스에 storm-cluster (storm 0.9.2 버전)를 배포하는 방법

AWS EC2에서 A 폭풍 클러스터를 배포하는 방법을 누구에게 말해 줄 수 있습니까? 몇 개의 링크가 지겨워졌지만 제대로 작동하지 않는 것 같습니다. 폭풍우 버전이 0.9.2이고이 버전이 AWS EC2와 호환되는지 또는 0.9.2보다 낮은 버전으로 이동해야합니까? 폭풍우 전개에 도움이되는 링크가 필요합니다. 나는 이미 링크 https://github.com

1열

1답변

스톰 스파우트에서 입력 파일을 읽을 수 없습니다.

로그 파일에서 읽는 스톰 스파우트가 있습니다. 따라서 코드를 로컬에서 테스트 할 때 작업을 실행하는 동안 런타임 인수를 전달하기 때문에 해당 코드가 잘 작동합니다. 그러나 클러스터에 코드를 배포 할 때 FileNotFoundException이 제공됩니다. 제 질문은 클러스터 시스템의 Spout에 입력을 전달하는 방법입니다. 리소스 위치를 사용하여 볼트에 대

0열

1답변

폭풍을 사용하여 트위터 데이터를 스트리밍 할 수 없습니다.

나는 Kantega/storm-twitter-workshop 프로젝트 link 에 따라 단계를 수행하고 있지만 한 지점에서 멈추었습니다. 나는 아래의 오류를 얻고있다 cd cheating mvn compile exec:java -Dexec.classpathScope=compile -Dexec.mainClass=storm.starter.CheatingTwit

0열

1답변

은 폭풍 토폴로지의 작업자 노드에서 집합 튜플의 실행을 지정합니다.

폭풍 토폴로지의 특정 작업자 노드에서 특정 필드를 기반으로 한 튜플 세트를 실행할 수 있습니까? 클러스터의 네트워크로드를 최소화해야합니다. 당신은 custom scheduler 갈 수