wait \ notify 프로세서 사용 방법 프로세서?

Question

nifi 인스턴스 1.2.0을 실행하고 있습니다.

난 그냥 참조에게 캔버스 http://ijokarumawak.github.io/nifi/2017/02/02/nifi-notify-batch/#why-mergecontent-dont-suffice

드래그 템플릿을 다음과 같이 프로세서를 사용하여 "대기 \ 통지"를 시도하고 나는 그것을 실행하려고합니다.

"Wait/Notify" 프로세서에서 다음 오류가 발생합니다.

Unable to communicate with cache when processing StandardFlowFileRecord[uuid=faab337f-034c-4137-a2f3-abb46f22b474,claim=StandardContentClaim [resourceClaim=StandardResourceClaim[id=1494485406343-1, container=default, section=1], offset=0, length=7005603],offset=5280310,name=input.csv,size=1054261] due to java.net.ConnectException: Connection refused: connect:

이 오류의 말씀 몰라?

난 그냥 바이너리 파일을 다운로드 전 1.2.0에 패치를 적용하고 아무것도 내가 놓친 해요 경우 어떤 경우가

저를 중지하십시오 시도하지입니까?

그리고 이것을 해결하도록 안내해주십시오.

Answer 1

DistributedMapCacheServer 및 DistributedMapCacheClient를 만들고 시작해야합니다. 클라이언트는 서버가 수신 대기중인 포트 및 호스트로 구성해야합니다.

그런 다음 Wait 및 Notify 프로세서는 DistributedMapCacheClient를 사용합니다.

프로세서를 시작할 수 있으므로 클라이언트 설정이 이미되어 있지만 서버가 실행 중이 아닙니다.