Realtime Compute for Apache Flink:Consulta de registros de trabajos históricos

Contexto

Requisitos previos

• Para consultar los registros de trabajos históricos en la pestaña Logs, asegúrese de que el archivado de registros esté habilitado. Esta función se encuentra habilitada de forma predeterminada y sus registros archivados se conservan durante 7 días. En la pestaña Configuration de un despliegue de Flink, expanda la sección Logging, active el interruptor Log Archiving y establezca el Archived Log Retention Period, por ejemplo, en 7 días.

• Para consultar los registros de trabajos históricos en OSS o SLS, debe haber configurado la salida de registros hacia OSS o SLS para dichos trabajos en Realtime Compute for Apache Flink. Para obtener más información, consulte Configure job log output.

Notas de uso

• Cuando un archivo de registro alcanza el tamaño especificado, el sistema lo archiva automáticamente y elimina periódicamente los archivos de registro que superan su periodo de retención. Los registros archivados se conservan incluso después de que un trabajo se detiene. Si se elimina un despliegue, también se eliminan sus registros asociados.

  Nota

  Después de que se publique new version en noviembre de 2024, todos los registros de trabajos existentes en la consola de Realtime Compute for Apache Flink, incluidos los registros archivados de trabajos detenidos, se eliminarán cuando expire su periodo de retención.

• Los registros se escriben en SLS u OSS solo si un TaskManager o el JobManager se inicia correctamente.

• Póngase en contacto con nosotros si no encuentra registros en OSS, lo cual puede ocurrir si el JobManager y los TaskManagers no logran iniciarse.

• De forma predeterminada, la configuración de registro conserva dos archivos de registro, cada uno con un tamaño de 5 MB. Se recomienda no modificar este valor; si necesita mayor capacidad de registro, exporte los registros a OSS. En la pestaña Configuration, dentro de la sección Logging, la configuración XML predeterminada de Log4j2 establece el size de SizeBasedTriggeringPolicy en 5 MB. Esto activa el archivado por rotación cuando un archivo de registro alcanza dicho tamaño. El atributo max de DefaultRolloverStrategy está establecido en 1.

  Nota

  La cantidad de archivos especificada en esta configuración no incluye el archivo que se está escribiendo actualmente. Por ejemplo, si max está establecido en 1, se conservan un máximo de dos archivos: uno activo y uno archivado.

Consulta de registros en la pestaña Logs

1. Inicie sesión en la consola de Realtime Compute for Apache Flink.

2. En la columna Actions del espacio de trabajo deseado, haga clic en Console.

3. En el panel de navegación izquierdo, seleccione O&M > Deployments.

4. Haga clic en el nombre del despliegue deseado.

5. Haga clic en la pestaña Logs.

6. En la pestaña Logs situada a la izquierda, seleccione un trabajo histórico en la lista desplegable Job.

   El panel izquierdo también contiene las pestañas Startup Logs y Exceptions. La lista desplegable separa los trabajos en Running jobs y Historical jobs.

7. Seleccione un registro para consultarlo.

   En la pestaña Job Manager o Running Task Managers, haga clic en el nombre de un registro para ver su contenido.

Consulta de registros en OSS

1. Inicie sesión en la consola de Object Storage Service (OSS).

2. En el panel de navegación izquierdo, haga clic en Buckets.

3. Haga clic en el name del bucket que configuró para su espacio de trabajo de Flink.

4. En la sección Artifacts, consulte la información de registros en el directorio correspondiente.

   Carpeta	Descripción
   artifacts	Almacena los paquetes JAR cargados.
   flink-jobs	Este directorio almacena los checkpoints de un trabajo de Flink.
   flink-savepoints	Este directorio almacena el archivo de savepoint que se crea al hacer clic en Create Savepoint para un despliegue en la página O&M > Deployments de la consola de Realtime Compute for Apache Flink.
   logs	Si configura el Logging Profile de su trabajo como OSS, este directorio almacena los registros del trabajo. Nota La ruta de almacenamiento de los registros de trabajo en el directorio logs es logs/${workspace-id}/${job-id}/${instance-id}. Puede utilizar esta estructura de directorios para localizar los registros del JobManager y del TaskManager correspondientes al trabajo.

Consulta de registros en SLS

1. Inicie sesión en la consola de Simple Log Service.

2. En la sección Projects, haga clic en el proyecto deseado.

3. En la pestaña Logstores, haga clic en el logstore deseado.

4. Introduzca una consulta, seleccione un rango de tiempo y haga clic en Search & Analyze.

   Para obtener más información, consulte Quick start for search and analysis.