TECH BLOG

코습장

커밋 메시지에는 무엇을 했는지보다 왜 했는지를 남기세요

전체 글 2

Spark Analysers 도입

모두가 Spark 전문가일 수는 없다. 그래서 사람이 일일이 잡지 않고, History Server 메트릭으로 안티패턴을 자동으로 잡아내는 분석기를 도입했다비효율적인 Spark 잡은 리소스를 상당히 많이 잡아먹는다. 하지만 이런 Spark 잡은 일일이 개발자가 잡아내는것은 사실상 불가능에 가깝다 느려지는 쿼리를 발견할때마다 Spark DAG를 분석하고 튜닝하고 이러한 과정은 많은 리소스가 들기 때문이다가장 큰 문제는 팀내에서는 다양한 사람들이 Spark를 이용해서 기능구현을 함에따라서 지식 깊이에 따라서 같은 기능이지만 속도차이가 유의미하게 발생하였다 이거를 일일이 체크하는것도 많은 리소스가 들었으며, 모니터링 및 계측 도구를 참고해서 성능 개선하는것도 많은 시간이 들었다그리고 시간이 지남에 따라서 빠르..

Spark 소형 파일 문제와 Iceberg를 택한 이유

데이터양은 얼마 안 되는데 Spark 조회만 느립니다. 어디를 봐야 원인이 나오고, 고친 뒤에는 무엇이 남을까요?왜 필요한가모델 학습 관련된 작업을 하던 중 학습과 추론 과정에서 소요시간이 너무 길게 잡히는 것을 확인했습니다.물론 학습에 필요한 데이터가 많기 때문에 어쩔 수 없이 오래 걸리는 건 당연하다고 생각했죠하지만 내가 생각했던 데이터량 대비 소요시간이 너무 길어 해당 현상을 조사하기 시작했습니다.우선 문제가 되는 API(학습 및 추론)의 소요시간을 측정해보기 시작했습니다. 학습 데이터 조회를 위해 약 10억 정도의 데이터를 조회하는 경우 위와같이 시간이 오래 걸리는것을 확인하게 되었다해당 글은 원인 확인을 위해 내가 확인했던 방법과 어떻게 해결하는지에 대한 과정을 담아 다른사람에게도 좋은 인사이트..