Spark 컨텍스트와 스트리밍 컨텍스트의 조합

Question

스트리밍 컨텍스트가 중단 된 후 일부 일괄 처리를 수행하고 싶습니다. (strContext.stop (true, true)

실제로 스트리밍 컨텍스트가 중지되면 연결된 스파크 컨텍스트가 중지되어 실제로 스파크 수신기 버스에 대한 오류가 발생합니다. strContext.stop (허위 사실)에 대한 호출은 스파크 컨텍스트의 실행 정지의 원인이됩니다.

이

사람이 스트리밍 후 일괄 계산의 예를 제공 할 수 있습니까?

Answer 1

def stop(stopSparkContext: Boolean, stopGracefully: Boolean): Unit = { 
    ... 
    if (stopSparkContext) sc.stop() 
} 

을 위의 코드에서 , spark strContext.stop (false)를 전달하면 컨텍스트를 중지하면 안됩니다.

코드에서 다른 부분을 멈추고 있습니까? 여기에 코드를 붙여 넣을 수 있습니까?