SPARK ARCHITECTURE AND EXECUTION MODEL EĞİTİMİ

Spark'ın motorunun içini derinlemesine kavra

Catalyst, Tungsten, DAG scheduler, shuffle ve bellek yönetimini öğrenip Spark işlerinin neden böyle çalıştığını kök düzeyde anlayın.

Apache Spark'ın iç mimarisini ve yürütme modelini kök düzeyde açıklayan ileri seviye eğitim: logical/physical plan ve Catalyst optimizer, Tungsten off-heap bellek ve whole-stage codegen, DAG scheduler ve job/stage/task bölünmesi, narrow/wide bağımlılıklar, sh…

3 gün İleri Seviye Online / Yüz Yüze / Hibrit Sertifikalı

Eğitim Hakkında

Catalyst/Tungsten, DAG scheduler, shuffle, bellek ve yürütme planı

Bu ileri seviye eğitim, Apache Spark'ın iç mimarisini ve yürütme modelini kök düzeyde açıklar. Katılımcılar logical plan'dan physical plan'a Catalyst optimizer'ı, Tungsten ile bellek yönetimi ve kod üretimini (whole-stage codegen), DAG scheduler'ın stage'lere bölme mantığını ve task scheduler'ı inceler. Shuffle mekanizması (shuffle write/read, sort-based shuffle, external shuffle service), partition ve paralellik, narrow/wide bağımlılıklar işlenir. Bellek yönetiminde unified memory model (execution/storage), spill, broadcast ve veri yerelliği (locality) ele alınır. Adaptive Query Execution, speculative execution ve iş yürütmesinin Spark UI'dan okunması derinlemesine incelenir. Eğitim, performans sorunlarının mimari düzeyde teşhisiyle tamamlanır.

Süre ve Format

3 Gün. Her gün dört modül; sorgu planından yürütme modeline, shuffle ve bellek yönetimine ilerlenir.

Seviye

İleri Seviye — Spark'ın iç mimarisi ve yürütme modeli: Catalyst, Tungsten, DAG scheduler, shuffle ve bellek yönetimi.

Öğrenme Metodu

Katılımcılar gerçek işlerin planlarını ve Spark UI metriklerini inceleyerek Catalyst, shuffle ve bellek davranışını uygulamalı analiz eder.

Neden Bu Eğitim?

🧠Derin Kavrayış

Catalyst ve Tungsten ile Spark'ın işi nasıl yürüttüğünü kök düzeyde anlarsınız.

🔀Shuffle Ustalığı

Shuffle write/read ve wide bağımlılıkların maliyetini çözümlersiniz.

🧮Bellek Modeli

Unified memory ve spill davranışını anlayıp OOM'u önlersiniz.

Anahtar Konular

spark mimarisispark yürütme modelicatalyst optimizertungstenspark shuffledag schedulerspark bellek yönetiminarrow wide dependencydata skewspark performans
“Spark'ı hızlandırmak için önce onu yavaşlatan şeyin motorun hangi katmanında olduğunu görmek gerekir.”

Ön Koşullar

Eğitimden verim almak için faydalı olacak bilgi ve ortam gereksinimleri

1
Spark Deneyimi

Spark DataFrame/SQL ile pratik deneyim güçlü biçimde faydalıdır.

2
Dağıtık Sistem

Paralellik ve küme kavramlarına aşinalık beklenir.

3
JVM Kavramı

JVM bellek ve GC kavramlarına temel aşinalık faydalıdır.

4
Çalışma Ortamı

Spark UI erişilebilen bir küme veya ortam.

Eğitim İçeriği

Programın gün gün akışı aşağıdadır. Bir güne tıklayarak o günün modüllerini ve içeriklerini görebilirsiniz.

Günün hedefiKatılımcı, Spark'ın bir sorguyu plana nasıl çevirdiğini kök düzeyde açıklayabilir.
Modül 1
Yürütme Katmanları
  • Unresolved logical plan ve analiz
  • Optimized logical plan
  • Physical plan ve seçim
  • RDD'ye dönüşüm (codegen)
  • DataFrame/SQL'in ortak plana derlenmesi
  • explain(mode='formatted') okuma
Modül 2
Catalyst Optimizer
  • Rule-based optimizasyon kuralları
  • Predicate/projection pushdown
  • Constant folding ve column pruning
  • Cost-based optimization (CBO)
  • İstatistik ve kardinalite tahmini
  • Optimizasyon kurallarının sırası
Modül 3
Tungsten
  • Off-heap bellek yönetimi
  • Binary row format (UnsafeRow)
  • Cache-aware hesaplama
  • Whole-stage code generation
  • Vectorized okuma
  • Tungsten'in CPU verimine katkısı
Modül 4
Plandan Yürütmeye
  • Physical operatörler (Exchange, Scan, HashAggregate)
  • Stage sınırının Exchange'de oluşması
  • WholeStageCodegen bloğu
  • Plan metriklerinin okunması
  • Plan ile UI eşleştirmesi
  • Plan tabanlı teşhis
Günün hedefiKatılımcı, Spark'ın işi stage ve task'lara nasıl böldüğünü analiz edebilir.
Modül 1
Job/Stage/Task
  • Action'ın job tetiklemesi
  • Stage'lere bölünme (shuffle sınırı)
  • Task'ın partition başına yürütülmesi
  • DAG scheduler ve task scheduler
  • Task serileştirme ve dağıtım
  • Paralellik ve slot kullanımı
Modül 2
Bağımlılık Türleri
  • Narrow dependency (map, filter)
  • Wide dependency (shuffle)
  • Bağımlılığın stage'e etkisi
  • Lineage ve yeniden hesaplama
  • Pipeline'lanabilir operatörler
  • Bağımlılığın hata kurtarmaya etkisi
Modül 3
Veri Yerelliği
  • Locality seviyeleri (PROCESS/NODE/RACK/ANY)
  • spark.locality.wait ayarı
  • Yerelliğin task süresine etkisi
  • Veri ve hesaplamanın birlikteliği
  • Yerellik düşüşünün nedenleri
  • Yerellik ve kaynak dengesi
Modül 4
Hata Toleransı
  • Task retry ve attempt
  • Stage yeniden hesaplama
  • Lineage tabanlı kurtarma
  • Speculative execution
  • Blacklisting/exclusion
  • Driver hatasının etkisi
Günün hedefiKatılımcı, shuffle ve bellek davranışını analiz edip performans sorunlarını teşhis edebilir.
Modül 1
Shuffle Mekanizması
  • Shuffle write ve read aşamaları
  • Sort-based shuffle
  • Shuffle dosyaları ve spill
  • External shuffle service
  • Shuffle partition sayısı
  • Shuffle'ın ağ ve disk maliyeti
Modül 2
Bellek Modeli
  • Unified memory (execution/storage)
  • On-heap ve off-heap bellek
  • Storage memory ve cache
  • Execution memory ve spill
  • Memory fraction ayarları
  • OOM nedenleri ve önlemi
Modül 3
Partition ve Skew
  • Partition boyutu ve sayısı dengesi
  • repartition vs coalesce
  • Veri çarpıklığının (skew) etkisi
  • Salting ile skew giderme
  • Küçük dosya problemi
  • Partition tabanlı optimizasyon
Modül 4
AQE ve Teşhis
  • Adaptive Query Execution bileşenleri
  • Dinamik partition coalescing
  • Skew join optimizasyonu
  • Runtime istatistik kullanımı
  • Spark UI ile darboğaz teşhisi
  • Mimari düzeyde performans kararları

Eğitim Kazanımları

Program sonunda katılımcılar:

✅
Plan Katmanları

Logical'dan physical plana derleme sürecini açıklarsınız.

✅
Catalyst

Catalyst optimizasyon kurallarını ve planı okursunuz.

✅
Tungsten

Off-heap bellek ve whole-stage codegen'i kavrarsınız.

✅
Job/Stage/Task

İşin stage/task'lara bölünmesini analiz edersiniz.

✅
Bağımlılık

Narrow/wide bağımlılık ve lineage'ı yorumlarsınız.

✅
Shuffle

Shuffle write/read ve spill maliyetini çözümlersiniz.

✅
Bellek

Unified memory modelini anlayıp OOM'u önlersiniz.

✅
Teşhis

Skew, AQE ve UI ile performans sorunlarını kök düzeyde çözersiniz.

Kimler İçin Uygundur?

  • Spark işlerini derinlemesine anlamak
  • performans sorunlarını kök nedenden çözmek isteyen kıdemli veri mühendisleri ve platform uzmanları için uygundur

Sıkça Sorulan Sorular

Bu eğitim kimler için uygundur?
Spark işlerini derinlemesine anlamak ve performans sorunlarını kök nedenden çözmek isteyen kıdemli veri mühendisleri ve platform uzmanları için uygundur.
Stage'ler neye göre oluşur?
Spark, wide bağımlılık (shuffle) gerektiren her nokta için yeni bir stage sınırı oluşturur; narrow bağımlılıklar aynı stage içinde pipeline'lanır. Eğitim bunu planlar üzerinden gösterir.
Shuffle neden pahalıdır?
Shuffle, veriyi partition'lar arasında diske yazıp ağ üzerinden yeniden dağıtır; disk, ağ ve serileştirme maliyeti getirir ve çoğu performans sorununun kaynağıdır.
OOM hatalarını nasıl önlerim?
Unified memory modelini, execution/storage dengesini, spill davranışını ve skew'i anlayarak partition ve bellek ayarını doğru yaparsınız; eğitim bunları mimari düzeyde ele alır.
Eğitim sonunda sertifika veriliyor mu?
Katılım ve değerlendirme sonrası Digital Vizyon Akademi Katılım ve Başarı Sertifikası verilir.

Sertifikalandırma

Bu eğitim Digital Vizyon Akademi Başarı Sertifikası ile tamamlanır.

Eğitim başında “Ön Test”, bitiminde “Son Test” uygulanarak gelişim ölçümlenir. Değerlendirme formunu dolduran katılımcılar sertifikalarını alır. Sertifikanızın geçerliliğini Sertifika Sorgulama sayfasından doğrulayabilirsiniz.

Örnek Sertifika d Digital Vizyon AKADEMİ KATILIM SERTİFİKASI Bu sertifika [Katılımcı Adı Soyadı] adlı katılımcının aşağıdaki eğitim programını başarıyla tamamladığını belgeler. Spark Architecture and Execution Model Eğitimi Sertifika Kodu DV-2026XX00 Tarih 26.10.2026 Yetkili İmza DV AKADEMİ

Eğitim Bilgileri

Süre3 gün
Seviyeİleri Seviye
FormatOnline / Yüz Yüze / Hibrit
Sertifika✓ Var
Hemen Bilgi Al
İlgili Eğitimler

Bu Eğitimle Birlikte Tercih Edilenler

Büyük Veri TeknolojileriCloudera Manager & Hadoop Clusters Eğitimi
Veri ve Analitik Eğitimleri

Cloudera Manager & Hadoop Clusters Eğitimi

3 günİleriOnline / Yüz Yüze / Hibrit

Cloudera Manager ile Hadoop kümelerini kurun, parcel ile servis dağıtın, yapılandırın ve yaşam döngüsünü yönetin. İleri seviye DVA eğitimi.

Detayları Gör →
Büyük Veri TeknolojileriCloudera Manager Administration Eğitimi
Veri ve Analitik Eğitimleri

Cloudera Manager Administration Eğitimi

3 günİleriOnline / Yüz Yüze / Hibrit

Cloudera Manager yönetimini öğrenin: RBAC yetkilendirme, LDAP, yapılandırma, izleme, uyarı ve BDR/snapshot ile yedekleme. İleri seviye DVA eğitimi.

Detayları Gör →
Büyük Veri TeknolojileriCloudera Manager Tools & Configuration Eğitimi
Veri ve Analitik Eğitimleri

Cloudera Manager Tools & Configuration Eğitimi

3 günOrtaOnline / Yüz Yüze / Hibrit

Cloudera Manager araçlarını, Chart Builder'ı, yapılandırma şablonlarını ve REST API otomasyonunu kullanarak kümeyi verimli yönetin. Orta seviye eğitim.

Detayları Gör →
Büyük Veri TeknolojileriConfluent Apache Kafka Yönetimi Eğitimi
Veri ve Analitik Eğitimleri

Confluent Apache Kafka Yönetimi Eğitimi

4 günİleriOnline / Yüz Yüze / Hibrit

Confluent Platform'da Kafka broker yönetimi, topic/partition tasarımı, replikasyon, SASL/SSL güvenlik, Schema Registry ve consumer lag izleme. İleri seviye eğit

Detayları Gör →
Büyük Veri TeknolojileriConfluent Apache Kafka: Küme İşlemleri ve Yapılandırma Eğitimi
Veri ve Analitik Eğitimleri

Confluent Apache Kafka: Küme İşlemleri ve Yapılandırma Eğitimi

3 günİleriOnline / Yüz Yüze / Hibrit

Kafka kümesini ölçeklendirin, partition yeniden atayın, broker/topic/istemci yapılandırmasını ve performansı ayarlayıp benchmark yapın. İleri seviye eğitim.

Detayları Gör →
+90 (501) 369 40 14 WhatsApp [email protected] LinkedIn