2016-08-29 2 views
0

연산자의 경우 입력 스트림이 출력 스트림보다 빠르기 때문에 입력 버퍼가이 연산자에 데이터를 전송하는 이전 연산자의 출력 스레드를 차단합니다. 권리?Apache Flink : 어떻게 배압을 처리합니까?

스레드를 차단하여 플린 크와 스파크가 모두 배압을 처리합니까? 그래서 그들 사이의 차이점은 무엇입니까?

데이터 소스의 경우 지속적으로 데이터를 생성하고 출력 스레드가 차단되면 어떻게됩니까? 버퍼 오버플로가 발생합니까?

답변

관련 문제