STREAMING_QUERY_EVOLUTION_ERROR felvillkor

SQLSTATE: 42000

Evolutionsfel för strömmande förfrågan

DUPLICATE_SOURCE_NAMES

Duplicerade källnamn för direktuppspelning har identifierats: <duplicateNames>. Varje strömmande källa måste ha ett unikt namn. Kontrollera att alla källor har distinkta namn med hjälp av metoden name().

OGILTIG_SÄNK_NAMN

Ogiltigt namn på mottagare för direktuppspelning: '<sinkName>'. Mottagarnamn får endast innehålla ASCII bokstäver ('a'-'z', 'A'-'Z'), siffror ('0'-'9') och understreck ('_') .

INVALID_SOURCE_NAME

Ogiltigt källnamn för direktuppspelning: '<sourceName>'. Källnamn får bara innehålla ASCII bokstäver ('a'-'z', 'A'-'Z'), siffror ('0'-'9') och understreck ('_') . Använd backticks för att citera namn med specialtecken om det behövs.

NAMNGIVNA_KÄLLOR_KRÄVER_TILLÄMPNING

Det går inte att använda metoden name() för att namnge strömmande källor när spark.sql.streaming.queryEvolution.enableSourceEvolution har inaktiverats. Aktivera källutveckling genom att ange spark.sql.streaming.queryEvolution.enableSourceEvolution till true eller ta bort anropet name().

NAMED_SOURCES_REQUIRE_OFFSET_LOG_V2

Namngivna strömningskällor kräver förskjutningsloggformat V2 (OffsetMap), men hittade V<version>. V2-format använder sourceId:offset-par som stöder källutveckling. Ange spark.sql.streaming.offsetLog.version till 2, eller inaktivera tvingande användning av namngivna källor genom att ställa in spark.sql.streaming.queryEvolution.enableSourceEvolution till false

SINK_ID ÅTERANVÄND

Det går inte att återanvända mottagarnamnet<sinkId> på kontrollpunktsplatsen <checkpointLocation>. Det här mottagarnamnet användes tidigare och ersattes sedan med en annan mottagare. Återanvändning av inaktiva mottagarnamn kan leda till problem med datakorrigering. Om du vill använda en ny mottagare tilldelar du den ett annat namn med hjälp av metoden name() på DataStreamWriter (till exempel .name("my_new_sink")).

SINK_PROVIDER_MISMATCH

Det går inte att ändra leverantör för '<sinkId>' vid kontrollpunkten <checkpointLocation>. Mottagaren använde tidigare leverantören '<previousProvider>' men använder nu '<currentProvider>'. Om du ändrar mottagartypen och behåller samma mottagarnamn kan det leda till problem med datakorrigering. Om du vill använda den nya mottagartypen tilldelar du den ett annat namn med hjälp av metoden name() på DataStreamWriter (till exempel .name("my_new_sink")).

TOMBSTONE_SOURCE_NAME_REUSE

Det går inte att återanvända tombstoned-källnamn: <sourceNames>. Dessa källnamn användes tidigare och togs sedan bort från strömningsfrågan på kontrollpunktsplatsen <checkpointLocation>. Återanvändning av tombstoned-källnamn kan leda till problem med datakorrigering. Använd olika källnamn.

ODJOURNADE_STREAMING_SINKS_MED_TVÅNG

En sink för direktuppspelning måste ha ett namn när spark.sql.streaming.queryEvolution.enableSinkEvolution är aktiverat. Använd metoden name() på DataStreamWriter för att tilldela ett namn till strömningsmottagaren.

UNNAMED_STREAMING_SOURCES_WITH_ENFORCEMENT

Alla strömmande källor måste namnges när spark.sql.streaming.queryEvolution.enableSourceEvolution är aktiverat. Namnlösa källor hittades: <sourceInfo>. Använd metoden name() för att tilldela namn till alla strömmande källor.