Deila með


STREAMING_CHECKPOINT_REWIND_ERROR error condition

SQLSTATE: 42000

Failed to perform rewind operation for streaming query with checkpoint location=<checkpointLocation>.

FAILED_TO_FIND_SINK_REWIND_PROVIDERS

Failed to find sink rewind providers at batchId=<batchId>.

FAILED_TO_FIND_SOURCE_REWIND_PROVIDERS

Failed to find source rewind providers at batchId=<batchId>.

INVALID_REWIND_PROVIDER

Found invalid source/sink rewind provider with name=<rewindProviderName> at batchId=<batchId>. Source/Sink provider name=<providerName> for <sourceOrSinkId>.

SINK_DOES_NOT_SUPPORT_REWIND_REPLAY

Sink <sinkName> does not support time travel. Please disable time travel or contact Databricks support.

SOURCE_ID_NOT_FOUND_IN_OFFSETS

Source ID '<sourceId>' at batchId=<batchId> was not found in the latest offset log at checkpoint location <checkpointLocation>.

Available source IDs: [<availableSourceIds>].

This error may occur if the streaming query was modified to add a new source after the rewind target batch.

Ensure all sources in the current query configuration existed at the target rewind batch.

SOURCE_OFFSET_METADATA_MISMATCH

Source offset metadata mismatch at batchId=<batchId>. Expected number of sources=<expectedNumSources>, but got count=<actualNumSources>.

TIME_TRAVEL_NOT_ENABLED

Time travel is not enabled for checkpoint location <checkpointLocation>. Please enable time travel before performing rewind. For new queries, enable time travel by setting spark.databricks.streaming.queryMgmt.rewindReplay.enabled to true.

UNSUPPORTED_OFFSET_LOG_VERSION

Unsupported offset log version <version> at batchId=<batchId>. Rewind requires offset log version 2. Ensure the checkpoint was created with offset log version 2 enabled.