apache-samza

1열

2답변

hello-samza 기본 설정을 따르려고하고 있으며 "Samza 작업 패키지 빌드"를 지나칠 수 없습니다. 지정된 내가 최근 내가 실행하려고 Gradle을 떨어져 실행하고 다음과 같음 : $ mvn clean package : $ ./gradlew publishToMavenLocal FAILURE: Build failed with an except

0열

1답변

얀이 노드를 얻지 못함

이것은 2 개의 작업 노드와 마스터가있는 AWS EMR 클러스터에 있습니다. 저는 원사 작업을 시작하는 hello-samza를 시도하고 있습니다. 작업이 ACCEPTED STATE 상태에서 멈춤. 나는 다른 게시물을 살펴 봤는데 내 마디가 노드가없는 것 같습니다. 어떤 원사가 작업 노드를 얻지 못했는지에 대한 도움이 도움이 될 것입니다. [[email pr

1열

2답변

Apache Samza에서 로컬 파일 시스템 및 hdfs 시스템에서 파일을 읽는 방법

Apache Samza에서 로컬 시스템 또는 HDFS 에서 파일을 읽는 방법을 찾고 필터를 적용하고 집계하며 조건을 정렬하고 데이터 순서 . 도움을주세요.

0열

2답변

Hello-samza - 작업이 허용 된 상태로 유지됩니다.

hello-samza 예제를 master 분기에서 시작하려고합니다. 모든 명령을 오류없이 실행했지만 오류없이 run-job.sh를 시작했지만 YARN의 작업은 ACCEPTED 상태로 영원히 유지됩니다. 나는 http://localhost:8088/cluster/nodes을 보았으며 아무 것도 표시하지 않습니다. 이것이 문제입니까? YARN에는 연결된 노드가

2열

2답변

YARN의 Samza는 KV 주 스토어를 어디에서 가져 옵니까?

YARN에서 Samza가 KV 상태 저장소를 배치하는 위치를 찾아야합니다. 나는 YARN 응용 프로그램 디렉토리에 모든 YARN 응용 프로그램이 있다고 의심하지만 다른 환경에서 몇 달 전에 이것을 메모리로 매핑했지만 지금은 기억하지 못한다고 생각합니다. 가능하기 때문에 다른 응용 프로그램의 다른 YARN 응용 프로그램 데이터에서 samza KV 저장소를 분

0열

1답변

KeyValueStore의 모든 요소를 처리하는 방법

KeyValueStore 유형의 KeyValueStore가 있습니다. 나는 열쇠의 범위를 모른다. samza에서 keyvaluestore 전체를 반복 할 수있는 방법이 있습니까? 감사합니다

1열

1답변

안녕하세요 - Samza NullPointException이

내가 는 하둡을 다운로드 그리드 스크립트의 단계를 수행 http://samza.apache.org/startup/hello-samza/0.11/ 헬로 samza 프로젝트, 카프카 & 사육사 구성을 시작하기 위해 그리드 스크립트를 사용하지 않은 얻을 동물원, hadoop, kafka가 그리드 스크립트에서와 같이 동물원, 원사, kafka를 시작합니다. 브라우

1열

1답변

Samza를 사용할 때 별도의 클러스터에서 체크 포인트, 코디네이터 및 변경 로그 카프카 항목 만들기

samza에서 kafka를 사용하는 경우 samza는 속성 파일의 이름을 사용하여 checkpoint, co-oridnator 및 changelog와 같은 특정 항목을 자동 생성합니다. 그러나 이러한 주제는 동일한 클러스터에서 작성됩니다. 하지만 유지 관리 목적으로 별도의 클러스터에 생성하려고합니다. 가능합니까?

0열

1답변

은 어떻게 samza 작업은 하나 이상의 카프카 스트림

내가이 개 주제를 소모 전형적인 samza 작업을 분할 소모 할 수 있습니다. 이 두 주제의 각각 하나의 파티션 만있는 경우 이 작업은 잘 작동합니다. data을 10 개의 파티션으로 분할하고 config을 하나의 파티션으로 남겨두면 상황이 바뀌 었습니다. task[0] -> config, data[0] task[1] -> data[1] ... task[9

1열

1답변

Apache Samza의 로깅 수준 높이기

Apache Samza의 로깅 수준을 변경하려고하므로 debug 문을 사용할 수 있습니다. 기본값은 info입니다. 더 구체적으로 말하자면, this debug statement을 표시하려고합니다. 저는 Clojure 프로젝트에서 Samza를 사용하고 있습니다. 이 작업을 수행하는 가장 좋은 방법은 무엇입니까? Samza Logging 페이지에는 유용한 정