Tüm Ürünler
Search

Bu Ürün

    Realtime Compute for Apache Flink:İş dağıtımını yapılandırma

    Belge Merkezi

    Realtime Compute for Apache Flink:İş dağıtımını yapılandırma

    Son Güncelleme:Oct 04, 2026

    Bir işi başlatmadan önce dağıtım ayarlarını yapılandırın.

    Önkoşullar

    Başlamadan önce aşağıdaki koşulları karşıladığınızdan emin olun:

    • Ad alanına erişmek ve iş kaynak yapılandırması gerçekleştirmek için gerekli izinlere sahip olmalısınız. Daha fazla bilgi için bkz. Ad alanlarında izin verme.

    • Dağıtım önceden oluşturulmuş olmalıdır. Daha fazla bilgi için bkz. İş dağıtma.

    Dağıtım ayarlarını yapılandırma

    1. Realtime Compute for Apache Flink konsoluna giriş yapın.

    2. Çalışma alanını bulun ve Actions sütunundaki Console öğesini tıklayın.

    3. Sol gezinme bölmesinde O&M > Deployments seçeneklerini belirleyin. Deployments sayfasında dağıtım adını tıklayın.

    4. Configuration sekmesinde düzenlemek istediğiniz bölümü bulun ve sağ üst köşesindeki Edit seçeneğini tıklayın.

    5. Aşağıdaki bölümlerdeki ayarları değiştirin:

    6. Save seçeneğini tıklayın.

    Basic

    Basic bölümünde aşağıdaki parametreler kullanılabilir. Kullanılabilirlik, dağıtım türüne bağlıdır.

    Parameter Deployment type Description
    Engine Version SQL, JAR, Python Kullanılacak Flink motor sürümü.
    Additional Dependencies SQL, JAR, Python Dağıtım için ek bağımlılık dosyaları.
    Description SQL, JAR, Python Dağıtıma ilişkin metin açıklaması.
    Label SQL, JAR, Python Dağıtımı organize etmek ve tanımlamak için kullanılan etiketler.
    JAR Uri JAR Çalıştırılacak JAR dosyasının URI değeri.
    Entry Point Class JAR Ana sınıfın tam nitelikli adı.
    Entry Point Main Arguments JAR, Python Giriş noktasına iletilen argümanlar.
    Kerberos Name JAR, Python Kimlik doğrulama için Kerberos asıl adı.
    Python Uri Python Çalıştırılacak Python dosyasının URI değeri.
    Entry Module Python Giriş noktası olarak kullanılacak Python modülü.
    Python Libraries Python Ek Python kitaplığı bağımlılıkları.
    Python Archives Python Python işi için gereken arşiv dosyaları.

    Parametre ayrıntıları için bkz. SQL taslağı geliştirme (SQL dağıtımları) veya İş dağıtma (JAR ve Python dağıtımları).

    Not

    SQL dağıtımları için Basic bölümündeki Edit seçeneğine tıklamak bir onay mesajı görüntüler. Onaylamak için OK seçeneğini tıklayın; bu işlem sizi SQL Editor sayfasına yönlendirir ve burada dağıtımı düzenleyip yeniden dağıtabilirsiniz.

    Parameters

    Checkpointing

    Parameter Description
    Checkpointing Interval Kontrol noktasının ne sıklıkla oluşturulacağını belirler. Ayarlanmazsa kontrol noktası devre dışı bırakılır.
    Checkpointing Timeout time Bir kontrol noktasının tamamlanması için izin verilen maksimum süre. Varsayılan: 10 dakika. Bu süre içinde tamamlanmayan kontrol noktası başarısız olur.
    Min Interval Between Checkpoints Ardışık iki kontrol noktası arasındaki minimum boşluk. Maksimum kontrol noktası paralellik değeri 1 olduğunda bu değer, kontrol noktaları arasındaki minimum aralığı tanımlar.

    State expiration

    Parameter Description
    State Expiration Time Dağıtım durum verilerinin yaşam süresi (TTL). Varsayılan: 36 h. Bu süre içinde erişilmeyen durum verileri durum arka ucundan otomatik olarak kaldırılarak bellek serbest bırakılır.
    Önemli

    Varsayılan TTL değeri olan 36 saat, Alibaba Cloud en iyi uygulamalarına dayanır ve durum verilerinin hiçbir zaman sona ermediği anlamına gelen Apache Flink varsayılanı 0'dan farklıdır. Hesaplama doğruluğu ve bellek kullanımı arasında denge kurmak için veri erişim kalıplarınıza göre TTL değerini ayarlayın.

    Durum verilerinin çalışma şekli:

    Veriler sisteme ilk girdiğinde durum arka ucunda depolanır. Aynı birincil anahtara sahip veriler tekrar geldiğinde Flink, depolanan duruma göre hesaplama yapar ve son erişim zamanını günceller. Verilere TTL süresi içinde tekrar erişilmezse Flink bunları süresi dolmuş olarak kabul eder ve kaldırır. TTL değerini düşürmek bellek tüketimini azaltır ve sistem kararlılığını artırır ancak gecikmeli gelen verilerin doğruluğunu etkileyebilir.

    Restart policy

    Flink, iş yeniden başlatma davranışını iki bağımsız mekanizma aracılığıyla kontrol eder: iş yeniden başlatma ilkesi ve görev hata kurtarma ilkesi.

    Job restart policy

    İş yeniden başlatma ilkesi, bir hatadan sonra işin yeniden başlayıp başlamayacağını ve nasıl başlayacağını belirler.

    Varsayılan davranış (açıkça bir ilke ayarlanmadığında):

    • Kontrol noktası etkinse: İş Fixed Delay kullanılarak yeniden başlatılır.

    • Kontrol noktası devre dışıysa: İş yeniden başlatılmaz.

    Varsayılanı geçersiz kılmak için şu ilkelerden birini seçin:

    Policy Description Additional parameters
    No Restarts Başarısızlık durumunda iş yeniden başlatılmaz. —
    Fixed Delay (varsayılan) Her başarısızlıktan sonra iş sabit bir aralıkla yeniden başlatılır. Number of Restart Attempts, Delay Between Restart Attempts
    Failure Rate Başarısızlık oranı tanımlanan eşikin altında kaldığı sürece iş yeniden başlatılır. Failure Rate Interval, Max Failures per Interval, Delay Between Restart Attempts

    Task failure recovery policy

    Görev hata kurtarma ilkesi, bir hata oluştuğunda hangi görevlerin yeniden başlatılacağını belirler. Other Configuration alanında jobmanager.execution.failover-strategy değerini ayarlayarak bunu yapılandırın.

    Value Behavior
    full Herhangi bir görev başarısız olduğunda tüm işi yeniden başlatır.
    region (varsayılan) Yalnızca başarısız olan ardışık düzen bölgesini kurtarmak için gereken minimum görev kümesini yeniden başlatır ve diğer bölgeleri etkilemez.
    Not

    failover-strategy değeri region olarak ayarlandığında, kurtarma sonrasında farklı bölgelerin farklı başlangıç zaman damgalarına sahip olması beklenen bir davranıştır.

    Daha fazla bilgi için Apache Flink belgelerindeki Task Failure Recovery konusuna bakın.

    Other configuration

    Ek Flink parametrelerini anahtar-değer çiftleri olarak ayarlamak için Other Configuration seçeneğini kullanın. Örnek:

    akka.ask.timeout: 10
jobmanager.execution.failover-strategy: full
    Not

    GC türü ayarları (örneğin -XX:+UseG1GC) env.java.opts aracılığıyla değiştirilemez.

    Logging

    Parameter Description
    Log Archiving Günlüklerin arşivlenip arşivlenmeyeceğini belirler. Varsayılan olarak etkindir. Etkinleştirildiğinde geçmiş dağıtım günlükleri Logs sekmesinde kullanılabilir. VVR 3.X'te yalnızca VVR 3.0.7 ve sonraki sürümler günlük arşivlemeyi destekler. VVR 4.X'te yalnızca VVR 4.0.11 ve sonraki sürümler günlük arşivlemeyi destekler. Daha fazla bilgi için bkz. Geçmiş bir dağıtımın günlüklerini görüntüleme.
    Log Archives Expires Arşivlenen günlüklerin ne kadar süreyle saklanacağını belirler. Varsayılan: 7 gün.
    Root Log Level Günlüğe kaydedilecek minimum önem düzeyi. Düzeyler aciliyet sırasına göre şunlardır: TRACE, DEBUG, INFO, WARN, ERROR.
    Log Levels Belirli günlük kaydediciler için özel günlük adı ve düzeyi çiftleri.
    Logging Profile Kullanılacak günlük şablonu. default veya Custom Template seçeneğini belirleyin. Custom Template, günlükleri harici depolamaya aktarmanıza olanak tanır. Daha fazla bilgi için bkz. Dağıtım günlüklerini dışa aktarmak için parametreleri yapılandırma.

    Referanslar