STREAMING_REAL_TIME_MODE felmeddelande

SQLSTATE: 0A000

Realtidsläget för direktuppspelning har följande begränsning:

ARBITRARY_STATEFUL_OPERATIONS_NOT_SUPPORTED

Den godtyckliga tillståndskänsliga strömningsoperatorn <op>stöds inte för närvarande. Vänligen se användarguiden för Real-Time-läge för en lista över operatorer som stöds.

ASYNC_PROGRESS_TRACKING_NOT_SUPPORTED

Asynkron förloppsspårning stöds inte i realtidsläge. Ange alternativet asyncProgressTrackingEnabled till false och försök igen med frågan.

ASYNC_STATE_CHECKPOINT_NOT_SUPPORTED

Kontrollpunkter för asynkrona tillstånd stöds inte i realtidsläge. Ställ in spark.databricks.streaming.statefulOperator.asyncCheckpoint.enabled på false och försök igen.

BATCH_UNION_NOT_SUPPORTED

Realtidsläget stöder inte union med batchdatakällor. Se till att den fackliga direktuppspelningsfrågan endast innehåller strömmande datakällor.

CLUSTER_CONFIGURATION_NOT_SUPPORTED

Följande konfigurationer stöds inte:

<invalidReasons>. Ange spark.databricks.streaming.realTimeMode.enabled till true i klusterkonfigurationen och ta bort <confNames> från klusterkonfigurationen om det finns och starta sedan om Spark-klustret.

DROP_DUPLICATES_WITHIN_WATERMARK_NOT_SUPPORTED

dropDuplicatesWithinWatermark stöds inte. Om du vill kringgå den här begränsningen kan du använda dropDuplicates i stället. Kom ihåg att skicka kolumnen event-time till dropDuplicates så att tillståndet kan tas bort.

EVENT_TIME_BASED_TIMERS_IN_TRANSFORM_WITH_STATE_NOT_SUPPORTED

Händelsetidsbaserade timers i transformWithState-operatorn stöds inte ännu. Om du vill använda transformWithState-operatorn anger du bearbetningstiden i transformWithState-operatorn och försöker sedan köra frågan igen.

EXACTLY_ONCE_SINK_INTE_STÖDD

Mottagare: <sink> levererar utdata exakt en gång, vilket inte stöds av realtidsläge. Ställ in mottagaralternativet "mode" på "atLeastOnce" och försök igen med frågan.

IDENTICAL_SOURCES_IN_UNION_NOT_SUPPORTED

Realtidsläget stöder inte union på två eller flera identiska strömmande datakällor i en enda fråga. Detta inkluderar scenarier som att referera till samma källdataram mer än en gång eller använda två datakällor med identiska konfigurationer för vissa källor. För Kafka bör du undvika att återanvända samma DataFrame och skapa olika. För Kinesis kontrollerar du, förutom att duplicera dataramar, att varje DataFrame anger ett unikt värde för alternativet "consumerName". Källor som anges i frågan: <sources>

INPUT_STREAM_NOT_SUPPORTED

Indataströmmen <className> stöds inte. En lista över indataströmmar som stöds finns i användarhandboken för Real-Time läge.

OPERATOR_OR_SINK_NOT_IN_ALLOWLIST

<errorType>(s): <message> inte i tillåtna listan för <errorType> läge Real-Time. Om du vill kringgå den här kontrollen anger du spark.databricks.streaming.realTimeMode.allowlistCheck till false. Genom att ändra detta godkänner du att köra frågan på egen risk.

OUTPUT_MODE_NOT_SUPPORTED

Utdataläget <outputMode> stöds inte. Om du vill kringgå den här begränsningen ställer du in utdataläget på Uppdatera. I framtiden kan <outputMode> stödjas.

SESSION_WINDOWS_NOT_SUPPORTED

Sessionsfönster stöds ännu inte. De enda aggregeringar med fönster som tillåts är över rullande och glidande fönster.

SHUFFLE_MORE_THAN_ONCE

Det finns <shuffleCount> strömmande shuffle-operatörer i den fysiska planen. Troligtvis anropar du de åtgärder som kräver shuffle mer än en gång, och RTM stöder inte detta. Om du vill köra frågan anger du spark.databricks.streaming.realTimeMode.allowlistCheck till false. Genom att ändra detta godkänner du att köra frågan på egen risk.

SINK_NOT_SUPPORTED

Diskhon <className> stöds för närvarande inte. För en lista över stödda mottagare, se användarhandboken för Real-Time-läget.

SQL_CONFIGURATION_NOT_SUPPORTED

Följande konfigurationer stöds inte:

<invalidReasons>. Ange spark.databricks.streaming.realTimeMode.enabled till true i klusterkonfigurationen och ta bort <confNames> från SparkSession-konfigurationen om det finns och starta sedan om Spark-klustret.

STATEFUL_OPERATORS_BEFORE_UNION_NOT_SUPPORTED

Strömningsfrågor i realtidsläge kan inte innehålla tillståndskänsliga operatorer (t.ex. aggregera, deduplicera, transformWithState) före en union. Omstrukturera förfrågan så att den tillämpar unionen innan tillståndskänsliga åtgärder.

STREAM_STREAM_JOIN_NOT_SUPPORTED

Ingen typ av strömningsanslutningar stöds ännu.