Notitie
Voor toegang tot deze pagina is autorisatie vereist. U kunt proberen u aan te melden of de directory te wijzigen.
Voor toegang tot deze pagina is autorisatie vereist. U kunt proberen de mappen te wijzigen.
Fout bij het ontwikkelen van streamingquery's:
DUPLICATE_SOURCE_NAMES
Dubbele streamingbronnamen gedetecteerd: <duplicateNames>. Elke streamingbron moet een unieke naam hebben. Zorg ervoor dat alle bronnen afzonderlijke namen hebben met behulp van de methode name().
ONGELDIGE SINK_NAAM
Ongeldige streaming-sinknaam: '<sinkName>'. Sinknamen mogen alleen letters ('a'-'z', 'A'-'Z'), cijfers ('0'-'9' en onderstrepingstekens ('_')) bevatten ASCII .
INVALID_SOURCE_NAME
Ongeldige streamingbronnaam: '<sourceName>'. Bronnamen mogen alleen letters ('a'-'z', 'A'-'Z'), cijfers ('0'-'9' en onderstrepingstekens ('_')) bevatten ASCII . Gebruik backticks om namen te citeren met speciale tekens, indien nodig.
GENOEMDE_BRONNEN_VEREISEN_HANDHAVING
Kan de methode name() niet gebruiken om streamingbronnen een naam te geven wanneer spark.sql.streaming.queryEvolution.enableSourceEvolution is uitgeschakeld. Schakel bronontwikkeling in door spark.sql.streaming.queryEvolution.enableSourceEvolution in te stellen op true of verwijder de naam() aanroep.
NAMED_SOURCES_REQUIRE_OFFSET_LOG_V2
Voor het afdwingen van benoemde streamingbronnen is de offset logboekindeling V2 (OffsetMap) vereist, maar we vonden V<version>. De V2-indeling maakt gebruik van sourceId:offset-koppels die ondersteuning bieden voor de evolutie van de bron. Stel spark.sql.streaming.offsetLog.version in op 2 of schakel het afdwingen van benoemde bronnen uit door spark.sql.streaming.queryEvolution.enableSourceEvolution in te stellen op false
SINK_ID_REUSED
Kan de sinknaam '<sinkId>' niet opnieuw gebruiken bij controlepuntlocatie <checkpointLocation>. Deze naam voor een sink is eerder gebruikt en vervolgens vervangen door een andere sinknaam. Het hergebruik van inactieve sinknamen kan leiden tot problemen met gegevensnauwkeurigheid. Als u een nieuwe sink wilt gebruiken, wijst u deze een andere naam toe met behulp van de methode name() in DataStreamWriter (bijvoorbeeld .name("my_new_sink")).
SINK_PROVIDER_MISMATCH
Kan de sinkprovider voor sink <sinkId> niet wijzigen op locatie <checkpointLocation> van het controlepunt. De sink gebruikte eerder provider '<previousProvider>' maar gebruikt nu '<currentProvider>'. Als u het sinktype wijzigt terwijl dezelfde sinknaam behouden blijft, kan dit leiden tot problemen met gegevens correctheid. Als u het nieuwe sinktype wilt gebruiken, wijst u deze een andere naam toe met behulp van de methode name() in DataStreamWriter (bijvoorbeeld .name("my_new_sink")).
TOMBSTONE_SOURCE_NAME_REUSE
Kan tombstoned bronnamen niet opnieuw gebruiken: <sourceNames>. Deze bronnamen werden eerder gebruikt en vervolgens verwijderd uit de streamingquery op de locatie van het controlepunt <checkpointLocation>. Het hergebruik van tombstoned-bronnamen kan problemen veroorzaken met gegevensnauwkeurigheid. Gebruik andere bronnamen.
ONGENOEMDE_STREAMING_ONTWIKKELINGEN_MET_HANDHAVING
De streaming-sink moet een naam hebben wanneer spark.sql.streaming.queryEvolution.enableSinkEvolution is ingeschakeld. Gebruik de methode name() in DataStreamWriter om een naam toe te wijzen aan de streaming-sink.
Ongenoemde streamingbronnen met afdwinging
Alle streamingbronnen moeten een naam hebben wanneer spark.sql.streaming.queryEvolution.enableSourceEvolution is ingeschakeld. Niet-benoemde bronnen gevonden: <sourceInfo>. Gebruik de methode name() om namen toe te wijzen aan alle streamingbronnen.