Apache Spark — 遅いジョブの答えは実行計画とイベントログにある
Spark 4.2 를 파드 하나에서 local 모드로 돌리며 잡·스테이지·태스크가 어떻게 나뉘는지, 스키마와 깨진 줄, SQL 과 DataFrame 의 같은 계획, 조건 밀어내기와 가지치기, 셔플 파티션과 AQE, 조인 전략과 쏠림, 캐시와 체크포인트, 파티션 레이크 쓰기, Structured Streaming 의 체크포인트와 워터마크까지 다룹니다. 모든 판정은 시간이 아니라 이벤트 로그의 계획·태스크 수·레코드 분포로 합니다. SQL 과 파이썬을 조금 써 본 분을 위한 과정입니다.
중급 · 레슨 30 · 실습 10
커리큘럼
ドライバーとジョブ
スキーマと壊れた行
- スキーマは推論に任せず、壊れた行は捨てずに選り分ける reading
- 取引先 CSV の壊れた行を三つのモードで読み込む lab
- クイズ: スキーマと壊れた行 quiz
DataFrame と SQL
実行計画を読む
シャッフルとパーティション数
結合戦略
- 結合は行の突き合わせ方でコストが十倍変わる reading
- 同じ結合を四つの戦略で実行し、実行計画で確かめる lab
- クイズ: 結合戦略 quiz
データの偏り
- タスク一つだけが終わらない理由はキー一つにある reading
- ボット一体がクリックの40%を占めるデータで偏りを測り、解消する lab
- クイズ: データの偏り quiz