apache-storm

0열

1답변

ProcessSimulator.killAllProcesses (줄 : 78) NoSuchMethodError ConcurrentHashMap.keySet()

이유가 무엇입니까? java.lang.NoSuchMethodError: java.util.concurrent.ConcurrentHashMap.keySet()Ljava/util/concurrent/ConcurrentHashMap$KeySetView; at org.apache.storm.ProcessSimulator.killAllProcesses(P

0열

1답변

슬라이딩 윈도우에서 현재 윈도우 시간을 얻는 방법은 무엇입니까? 나는 폭풍의 구현에 의해 슬라이딩 창으로 사용하고

: 나는 창문이 시작되는 타임 스탬프를 좀하고 싶습니다 내 SlidingWindowStatisticsBolt의에서 public static void main(String[] args) throws Exception { TopologyBuilder builder = new TopologyBuilder(); builder.setSpout("

0열

1답변

Storm에서 스파우트를 테스트하는 방법

실제로 큐에서 읽고 튜플로 메시지를 내 보내는 Apache Storm 스파우트를 단위 테스트하는 작업에 어려움을 겪고 있습니다. 임베디드 큐를 사용하고 큐에 메시지를 넣고 내 스파우트에서 메시지를 내보내려고합니다. 누구든지 그 목적을 달성하는 데 도움이 될 수 있습니까?

0열

1답변

토폴로지 이름이

인 특수 문자가 포함 된 스톰 토폴로지를 종료합니다. 따라서 -local이라는 이름으로 배포 된 스톰 스타터 (storm-starter) 중 하나에서 스톰 토폴로지를 얻었습니다. 이름이 인수로 해석되므로 kill으로 보내려고하면 너무 행복하지 않습니다. 나는 이중 따옴표 등으로 이름을 헛되이 전달하려고 시도했다. 다른 방법이 있습니까? | 1) 토폴로지를

0열

1답변

스파우트 로직 오류

이 문제에 도움이 필요합니다. 나는 스파우트가 데이터를 읽거나 Bolt에서 처리하기 위해 그것을 준비 할 책임이 있음을 읽었습니다. 그래서 스파우트에 파일을 열고 줄 단위로 읽을 코드를 썼습니다. class SimSpout(storm.Spout): # Not much to do here for such a basic spout def in

0열

1답변

작업자가 폭풍으로 사망 한 경우의 필드 그룹화

특정 ID의 카운터를 유지 관리하기 위해 로컬 캐시를 사용하는 유스 케이스가 있습니다. 토폴로지 클래스에서 fieldsGrouping("spout", new Fields("id"))을 수행했습니다. id1이 항상 processingBolt에서 worker1으로 처리되고 id2이 항상 processingBolt에서 worker2으로 처리되었다고 가정 해 봅시

0열

1답변

여러 아파치 스톰 볼트 작업 사이에서 동시 해시 맵 공유하기

나는 특정 튜플에서 해시 맵에 키와 값을 쓰고 다른 사람에게 저장된 키를 사용하여 해시 맵에서 값을 읽는 스톰 볼트가 있습니다. 작업 수가 1로 설정되면 잘 작동하지만이 숫자를 늘리 자마자 키가 없어야 할 때 키가 null 값을 반환하기 시작합니다. 각 볼트 작업이 해시 맵의 자체 인스턴스를 만들어 데이터가 공유되지 않기 때문에 이것이라고 가정합니다. 어떻

0열

1답변

형식 오류 : <파일 열기 '데이터'모드 'R'은 JSON없는 직렬화

내가 포함 된 파일을 여는 오류가 발생했습니다 rt @whufc_news : west ham are the only team in the top half of the premier league without a player in the england squad . !url rt @blackpplvines : don't say anything just rt

0열

1답변

Apache Strom 필드 그룹화는 여러 작업자에서 작동합니까?

필드 내용과 작업 ID를 함께 해싱하는 방법을 사용하여 동일한 볼트 작업으로 이동하는 필드에서 모든 튜플을 동일한 값으로 유지하는 방법을 확인할 수 있습니다. 그러나 한 명 이상의 근로자가있는 경우 어떻게 할 수 있습니까? 확실히 볼트 작업은 근로자들 사이에서 공유되지 않습니까?

0열

1답변

collector.fail은 무엇을합니까?

apache storm에서 collector.fail은 무엇을합니까? 원본 (스파우트)에서 튜플을 재생하거나 출력 된 마지막 볼트에서 튜플을 재생 만합니까? 참고 : 내 튜플을 고정하지 않으므로이 경우 어떻게됩니까?