STREAMING_QUERY_EVOLUTION_ERROR chybový stav

SQLSTATE: 42000

Chyba vývoje dotazu streamování:

DUPLICITNÍ_NÁZVY_ZDROJŮ

Byly zjištěny duplicitní názvy zdrojů streamování: <duplicateNames>. Každý zdroj streamování musí mít jedinečný název. Ujistěte se, že všechny zdroje mají odlišné názvy pomocí metody name().

NEPLATNÝ_NÁZEV_SINKU

Neplatný název cíle streamování:<sinkName> Názvy jímky musí obsahovat ASCII pouze písmena ('a'-'z', 'A'-'Z'), číslice ('0'-'9') a podtržítka ('_') .

INVALID_SOURCE_NAME

Neplatný název zdroje streamování:<sourceName> Názvy zdrojů musí obsahovat ASCII pouze písmena ('a'-'z', 'A'-'Z'), číslice ('0'-'9') a podtržítka ('_') . V případě potřeby použijte zpětné apostrofy k ohraničení názvů se speciálními znaky.

POJMENOVANÉ_ZDROJE_VYŽADUJÍ_VYNUTIT

Metodu name() nelze použít k pojmenování streamovaných zdrojů při zakázání spark.sql.streaming.queryEvolution.enableSourceEvolution. Povolte vývoj zdroje nastavením spark.sql.streaming.queryEvolution.enableSourceEvolution na true nebo odeberte volání name().

NAMED_SOURCES_REQUIRE_OFFSET_LOG_V2

Vynucení pojmenovaných zdrojů streamování vyžaduje formát odsazení protokolu V2 (OffsetMap), ale místo toho bylo nalezeno V<version>. Formát V2 používá páry sourceId:offset, které podporují vývoj zdroje. Nastavte spark.sql.streaming.offsetLog.version na 2 nebo zakažte vynucení pojmenovaných zdrojů nastavením spark.sql.streaming.queryEvolution.enableSourceEvolution na false.

SINK_ID_ZNOVU_POUŽITÉ

Nelze znovu použít název jímky '<sinkId>' v umístění kontrolního bodu <checkpointLocation>. Tento název jímky byl dříve použit a potom nahrazen jiným jímkou. Opakované opakované nasazení názvů neaktivních jímek může vést k problémům se správností dat. Pokud chcete použít novou jímku, přiřaďte jí jiný název pomocí metody name() na DataStreamWriter (například .name("my_new_sink")).

SINK_PROVIDER_MISMATCH

Nelze změnit poskytovatele jímky pro jímku '<sinkId>' v umístění kontrolního bodu <checkpointLocation>. Jímka dříve používala poskytovatele '<previousProvider>', ale teď používá '<currentProvider>'. Změna typu jímky a zachování stejného názvu jímky může vést k problémům se správností dat. Pokud chcete použít nový typ jímky, přiřaďte ho jiným názvem pomocí metody name() na DataStreamWriter (například .name("my_new_sink")).

TOMBSTONE_SOURCE_NAME_REUSE

Nelze znovu použít označené názvy zdrojů: <sourceNames>. Tyto názvy zdrojů byly dříve použity a pak odebrány ze streamovacího dotazu v umístění kontrolního bodu <checkpointLocation>. Opětovné použití archivovaných zdrojových názvů může vést k problémům se správností dat. Použijte jiné názvy zdrojů.

Nepojmenované streamové dřezy s vynucením

Pokud je povolená spark.sql.streaming.queryEvolution.enableSinkEvolution, musí být jímka streamování pojmenována. Pomocí metody name() na DataStreamWriter přiřaďte název jímce streamování.

Nejménované zdroje streamování s prosazením

Pokud je povolená možnost spark.sql.streaming.queryEvolution.enableSourceEvolution, musí být pojmenovány všechny zdroje streamování. Nalezeny nepojmenované zdroje: <sourceInfo>. Pomocí metody name() přiřaďte názvy ke všem zdrojům streamování.