2020.05.25 오늘의 일지

SparkSession을 종료할 일이 생겼다.

종료 요청이 온 경우

SparkSession.stop()과 SparkSession.close()를 사용해 종료를 하고

 

이를 SparkSession.sparkContext().isStopped()를 통해 종료했는지 아닌지를 체크해 연관된 다른 프로세스에서도 종료하도록 설정함.

 

뜯어봐야될 부분이 좀 더 많아진 느낌.