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ğu özelliğini devre dışı bırakın veya Databricks desteğine başvurun.

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.