Hinweis
Für den Zugriff auf diese Seite ist eine Autorisierung erforderlich. Sie können versuchen, sich anzumelden oder das Verzeichnis zu wechseln.
Für den Zugriff auf diese Seite ist eine Autorisierung erforderlich. Sie können versuchen, das Verzeichnis zu wechseln.
Fehler bei der Streamingabfrageentwicklung:
DUPLIKATE_QUELLNAMEN
Doppelte Namen der Streamingquelle erkannt: <duplicateNames>. Jede Streamingquelle muss einen eindeutigen Namen haben. Stellen Sie sicher, dass alle Quellen über unterschiedliche Namen verfügen, indem Sie die Name()-Methode verwenden.
UNGÜLTIGER_SINK_NAME
Ungültiger Streaming-Sinkname: '<sinkName>'. Senkennamen dürfen nur Buchstaben ('a'-'z', 'A'-'Z'), Ziffern ('0'-'9') und Unterstriche ('_') enthalten ASCII .
INVALID_SOURCE_NAME
Ungültiger Name der Streamingquelle: '<sourceName>'. Quellnamen dürfen nur Buchstaben ('a'-'z', 'A'-'Z'), Ziffern ('0'-'9') und Unterstriche ('_') enthalten ASCII . Verwenden Sie bei Bedarf Backticks, um Namen mit Sonderzeichen zu kennzeichnen.
QUELLEN_MÜSSEN_DURCHSETZUNG_ERFORDERN
Die Name()-Methode kann nicht zum Benennen von Streamingquellen verwendet werden, wenn spark.sql.streaming.queryEvolution.enableSourceEvolution deaktiviert ist. Aktivieren Sie die Quellentwicklung, indem Sie spark.sql.streaming.queryEvolution.enableSourceEvolution auf "true" festlegen oder den Namen()-Aufruf entfernen.
NAMED_SOURCES_REQUIRE_OFFSET_LOG_V2
Für die Erzwingung benannter Streamingquellen ist das Offsetprotokollformat V2 (OffsetMap) erforderlich, aber V<version> gefunden. Das V2-Format verwendet sourceId:offset-Paare, die die Quellentwicklung unterstützen. Legen Sie spark.sql.streaming.offsetLog.version auf 2 fest, oder deaktivieren Sie die Erzwingung benannter Quellen, indem Sie spark.sql.streaming.queryEvolution.enableSourceEvolution auf "false" festlegen.
SINK_ID_REUSED
Der Sinkname '<sinkId>' kann am Prüfpunktort <checkpointLocation> nicht wiederverwendet werden. Dieser Senkenname wurde zuvor verwendet und dann durch eine andere Spüle ersetzt. Das Wiederverwenden von inaktiven Senkennamen kann zu Problemen mit der Datenkorrektur führen. Um ein neues Sink zu verwenden, weisen Sie ihm mit der name()-Methode von DataStreamWriter (z. B. .name("my_new_sink")) einen anderen Namen zu.
SINK_PROVIDER_UNSTIMMIGKEIT
Der Sinkanbieter für Spüle '<sinkId>' kann nicht an Prüfpunktstandort <checkpointLocation>geändert werden. Die Spüle wurde zuvor vom Anbieter '<previousProvider>' verwendet, aber jetzt verwendet '<currentProvider>'. Das Ändern des Spülentyps bei gleichzeitiger Beibehaltung des gleichen Sinknamens kann zu Problemen mit der Datenkorrektur führen. Um den neuen Senkentyp zu verwenden, weisen Sie ihn mit der Name()-Methode für DataStreamWriter (z. B. .name("my_new_sink")) einem anderen Namen zu.
TOMBSTONE_SOURCE_NAME_REUSE
Grabsteinquellnamen können nicht wiederverwendet werden: <sourceNames>. Diese Quellnamen wurden zuvor verwendet und dann aus der Streamingabfrage am Prüfpunktspeicherort <checkpointLocation>entfernt. Das Wiederverwenden von Grabsteinquellnamen kann zu Problemen mit der Datenkorrektur führen. Bitte verwenden Sie unterschiedliche Quellnamen.
Unbenannte Streaming-Sinks mit Durchsetzung
Die Streaming-Sink muss benannt sein, wenn spark.sql.streaming.queryEvolution.enableSinkEvolution aktiviert ist. Verwenden Sie die Name()-Methode auf DataStreamWriter, um dem Streaming-Sink einen Namen zuzuweisen.
UNBENANNTE_STREAMING_QUELLEN_MIT_DURCHSETZUNG
Alle Streamingquellen müssen benannt werden, wenn spark.sql.streaming.queryEvolution.enableSourceEvolution aktiviert ist. Nicht benannte Quellen gefunden: <sourceInfo>. Verwenden Sie die Name()-Methode, um Allen Streamingquellen Namen zuzuweisen.