Compartir a través de


STREAMING_CHECKPOINT_METADATA_ERROR estado de error

SQLSTATE: 42616

Error en los metadatos del punto de control de streaming.

COMMIT_LOG_V3_MISSING_SINK_METADATA

Si usa spark.sql.streaming.commitLog.formatVersion >= 3, se debe proporcionar información de metadatos del sink. Algunos modos de streaming son incompatibles con esta versión de formato (modo continuo, seguimiento de progreso asincrónico, punto de control de estado asincrónico); Corrija las configuraciones e inténtelo de nuevo.

DETECTADO_LOTE_DE_CONTROL_PENDIENTE

Se detectó un lote de control pendiente para operationType=<operationType> con batchId=<batchId> y queryId=<queryId>. Vuelva a intentar la operación de control y vuelva a ejecutar la consulta.

CONSULTA_EN_EJECUCIÓN_DETECTADA

Se detectó la ejecución de una consulta de streaming con el identificador <queryId>. Detenga la consulta en ejecución antes de realizar el retroceso.

INVALID_COMMIT_LOG_METADATA

Se encontraron metadatos no válidos en el registro de confirmación para el lote <batchId> con versión de formato <commitLogFormatVersion>. Vuelva a ejecutar la consulta con la configuración correcta.

PROGRESO_FALTANTE_EN_COMMIT

Error al habilitar el viaje en el tiempo para el lote <batchId>. Deshabilite el viaje en el tiempo o póngase en contacto con el soporte técnico de Databricks.

NO_QUERY_ID_FOUND

No se encontró ningún identificador de consulta de streaming en la ubicación <checkpointLocation>del punto de control . Compruebe si la ubicación del punto de control es válida.

REWIND_COMMIT_MISSING_SINK_METADATA

Se intentó retroceder al lote <batchId> en la ubicación del punto de control <checkpointLocation>, pero no se creó con spark.sql.streaming.commitLog.formatVersion >= 3. No hay metadatos de destino disponibles en el registro de confirmación. Por favor, vuelva a intentarlo con un lote que tenga metadatos de fregadero disponibles, o vuelva a ejecutar la consulta con la configuración correcta.

REWIND_OFFSET_FALTA_DE_METADATOS

Se intentó rebobinar al lote <batchId> en la ubicación <checkpointLocation> del punto de control, pero no hay metadatos disponibles en el registro de desplazamiento. Vuelva a intentarlo con un lote que tenga metadatos disponibles.

SKIP_OFFSETS_INVALID_SOURCE_ID

El identificador <sourceId> de origen no válido en skipOffsets en batchId=<batchId> no existe en los identificadores de origen disponibles=<availableSourceIds> para la ubicación <checkpointLocation> del punto de control. Compruebe si la consulta se modificó para quitar este origen y volver a agregarla.

LA_FUENTE_NO_SOPORTA_DESPLAZAMIENTOS_OMITIDOS

El origen <sourceName> no admite la omisión de offsets. Elimine esta fuente de la consulta o retroceda sin omitir desplazamientos.