STREAMING_QUERY_EVOLUTION_ERROR hata durumu

SQLSTATE: 42000

Akış sorgusu gelişim hatası:

KAYNAK_ADLARI_ÇİFTLEME

Yinelenen akış kaynağı adları algılandı: <duplicateNames>. Her akış kaynağının benzersiz bir adı olmalıdır. Lütfen name() yöntemini kullanarak tüm kaynakların farklı adlara sahip olduğundan emin olun.

GEÇERSİZ_SINK_ADI

Geçersiz akış havuzu adı: '<sinkName>'. Havuz adları yalnızca harf ('a'-'z', 'A'-'Z'), rakamlar ('0'-'9') ve alt çizgi ('_') içermelidir ASCII .

INVALID_SOURCE_NAME

Geçersiz akış kaynağı adı: '<sourceName>'. Kaynak adları yalnızca harf ('a'-'z', 'A'-'Z'), rakamlar ('0'-'9') ve alt çizgi ('_') içermelidir ASCII . Gerekirse adları özel karakterlerle belirtmek için ters tırnak işaretleri kullanın.

ADLANDIRILMIŞ_KAYNAKLAR_ZORUNLU_KILINMALI

spark.sql.streaming.queryEvolution.enableSourceEvolution devre dışı bırakıldığında akış kaynaklarını adlandırmak için name() yöntemi kullanılamaz. lütfen spark.sql.streaming.queryEvolution.enableSourceEvolution ayarını true olarak ayarlayarak kaynak evrimini etkinleştirin veya name() çağrısını kaldırın.

NAMED_SOURCES_REQUIRE_OFFSET_LOG_V2

Adlandırılmış akış kaynakları zorlaması için ofset günlüğü biçimi V2 (OffsetMap) gerekir, ancak V<version> bulundu. V2 biçimi, kaynak evrimini destekleyen sourceId:offset çiftlerini kullanır. spark.sql.streaming.offsetLog.version değerini 2 olarak ayarlayın veya spark.sql.streaming.queryEvolution.enableSourceEvolution değerini false olarak ayarlayarak adlandırılmış kaynak zorlamasını devre dışı bırakın

SINK_KİMLİĞİ_TEKRAR KULLANILDI

Kontrol noktası konumunda <sinkId> sink adı '<checkpointLocation>' yeniden kullanılamaz. Bu sink adı daha önce kullanılmış ve ardından farklı bir sink ile değiştirilmiştir. Etkin olmayan havuz adlarını yeniden kullanmak veri doğruluğu sorunlarına yol açabilir. Yeni bir havuz kullanmak için DataStreamWriter'da name() yöntemini (örneğin, .name("my_new_sink") kullanarak bu havuza farklı bir ad atayın.

SINK_PROVIDER_MISMATCH (Hedef Sağlayıcı Uyumsuzluğu)

Denetim noktası konumunda <sinkId>'<checkpointLocation>' havuzu için havuz sağlayıcısı değiştirilemez. Havuz daha önce '<previousProvider>' sağlayıcısını kullanıyordu ama şimdi '<currentProvider>' kullanıyor. Aynı havuz adını tutarken havuz türünü değiştirmek veri doğruluğu sorunlarına yol açabilir. Yeni havuz türünü kullanmak için DataStreamWriter'da name() yöntemini (örneğin, .name("my_new_sink")) kullanarak farklı bir ad atayın.

TOMBSTONE_KAYNAK_ADI_YENİDEN_KULLANма

Kaldırıldı olarak İşaretlenen kaynak adları yeniden kullanılamaz: <sourceNames>. Bu kaynak adları daha önce kullanıldı ve denetim noktası konumundaki <checkpointLocation>akış sorgusundan kaldırıldı. Silinmek üzere işaretlenmiş kaynak adlarını yeniden kullanmak veri doğruluğu sorunlarına yol açabilir. Lütfen farklı kaynak adları kullanın.

UNNAMED_STREAMING_SINKS_WITH_ENFORCEMENT

spark.sql.streaming.queryEvolution.enableSinkEvolution etkinleştirildiğinde akış havuzu adlandırılmalıdır. Akış havuzuna bir ad atamak için DataStreamWriter'da name() yöntemini kullanın.

İsimsiz Yayın Kaynakları ile Uygulama

spark.sql.streaming.queryEvolution.enableSourceEvolution etkinleştirildiğinde tüm akış kaynakları adlandırılmalıdır. Adsız kaynaklar bulundu: <sourceInfo>. Tüm akış kaynaklarına ad atamak için name() yöntemini kullanın.