STREAMING_CHECKPOINT_METADATA_ERROR hata durumu

SQLSTATE: 42616

Akış denetim noktası meta verilerinde hata oluştu.

COMMIT_LOG_V3_MISSING_SINK_METADATA

spark.sql.streaming.commitLog.formatVersion >= 3 kullanılıyorsa havuz meta veri bilgileri sağlanmalıdır. Bazı akış modları bu biçim sürümüyle uyumsuz (sürekli mod, zaman uyumsuz ilerleme izleme, zaman uyumsuz durum denetim noktası oluşturma); lütfen yapılandırmaları düzeltin ve yeniden deneyin.

TESPİT_EDİLMİŞ_BEKLEYEN_KONTROL_TOPLAMI

operationType=<operationType> ile batchId=<batchId> ve queryId=<queryId> için beklemedeki denetim toplu işlemi algılandı. Denetim işlemini yeniden deneyin ve sorguyu yeniden çalıştırın.

ÇALIŞAN SORGULAR TESPİT EDİLDİ

kimliği <queryId> olan bir akış sorgusunun çalıştığı algılandı. Geri sarma işlemi gerçekleştirmeden önce çalışan sorguyu durdurun.

INVALID_COMMIT_LOG_METADATA

Biçim sürümü <batchId> olan toplu iş <commitLogFormatVersion> için geçersiz işleme günlüğü meta verileri bulundu. Lütfen sorguyu doğru yapılandırmayla yeniden çalıştırın.

MISSING_COMMIT_PROGRESS

Toplu iş <batchId> için zaman yolculuğu etkinleştirildiğinde hata oluştu. Lütfen zaman yolculuğunu devre dışı bırakın veya Azure Databricks destek ile iletişime geçin.

MISSING_METADATA_FILE

Denetim noktası konumu <checkpointLocation> tutarsız bir durumda: meta veri dosyası eksik, ancak ofset ve/veya commit günlükleri veri içeriyor. Lütfen meta veri dosyasını geri yükleyin veya yeni bir denetim noktası dizini oluşturun.

NO_QUERY_ID_FOUND

Denetim noktası konumunda <checkpointLocation>akış sorgusu kimliği bulunamadı. Denetim noktası konumunun geçerli olup olmadığını denetleyin.

REWIND_COMMIT_MISSING_SINK_METADATA

Denetim noktası konumunda <batchId> toplu işleme <checkpointLocation> geri sarma denendi ancak spark.sql.streaming.commitLog.formatVersion >= 3 ile oluşturulmadı. İşleme günlüğünde kullanılabilir havuz meta verileri yok. Lütfen havuz meta verilerinin kullanılabilir olduğu bir toplu işlemi yeniden deneyin veya sorguyu doğru yapılandırmayla yeniden çalıştırın.

GERİYA SARMA_BAŞLANGIÇ_KAYIP_METAVERİ

Denetim noktasında <batchId> numaralı toplu işleme geri sarılmaya çalışıldı, ancak ofset günlüğünde meta veri yok. Lütfen meta verilerin kullanılabilir olduğu bir toplu işlemle yeniden deneyin.

SKIP_OFFSETS_INVALID_SOURCE_ID

batchId=<sourceId> konumunda skipOffsets içinde geçersiz kaynak kimliği<batchId>, denetim noktası konumu <availableSourceIds>için kullanılabilir kaynak kimliklerinde<checkpointLocation> yok. Lütfen sorgunun bu kaynağı kaldırmak ve yeniden eklemek için değiştirilip değiştirilmediğini denetleyin.

KAYNAK_ATLAMALI_OFFSETLERİ_DESTEKLEMİYOR

Kaynak <sourceName> , uzaklıkların atlanmasını desteklemiyor. Lütfen bu kaynağı sorgudan kaldırın veya uzaklıkları atlamadan geri sarmalayın.

STATE_METADATA_MISSING_FOR_REWIND

Geri sarma işlemi sırasında toplu iş <operatorId> sırasında işleç <batchId> için durum meta verileri okunamadı. Denetim noktası konumu: <checkpointLocation>. Meta veri dosyası bu toplu iş için mevcut olmayabilir. Hedef paketin geri sarılmadan önce geçerli durum meta verilerine sahip olduğundan emin olun.

STATE_STORE_MIGRATION_WITH_TIME_TRAVEL_UNSUPPORTED

Zaman yolculuğunu etkinleştirmek ve aynı sorgu yeniden başlatmasında eyalet mağazası sağlayıcısını taşımak desteklenmiyor. Önce eyalet mağaza sağlayıcı geçişini tamamla, ardından bir sonraki yeniden başlatmada zaman yolculuğunu etkinleştirin. Denetim noktası konumu: <checkpointLocation>.