Realtime Compute for Apache Flink:Iniciar un despliegue

Requisitos previos

Se requiere un despliegue existente. Para obtener más información, consulte Create a deployment.

Limitaciones

Solo puede especificar opciones de inicio para un despliegue de streaming.

Precauciones

• Si un usuario de RAM, un rol de RAM u otra cuenta de Alibaba Cloud inicia un despliegue, asegúrese de que la identidad correspondiente tenga acceso al namespace de destino. Para obtener más información, consulte Authorize access to the fully managed Flink console y Manage permissions.

• Si inicia un despliegue mediante la opción Latest State o Specific State, el sistema realiza una comprobación de compatibilidad de estado. Iniciar un despliegue con incompatibilidades detectadas conlleva riesgos, ya que podría fallar o producir resultados inesperados. Para obtener más información, consulte Flink state compatibility reference.

Procedimiento

1. Abra el cuadro de diálogo Start del despliegue.

   1. Inicie sesión en la consola de Flink totalmente gestionada como un usuario que tenga el rol de propietario del namespace.

   2. En la barra de navegación superior, seleccione el namespace de destino.

   3. En la página O&M > Deployments, seleccione STREAM o BATCH en la lista desplegable.

2. Busque el despliegue de destino y, en la columna Actions, haga clic en Start.

3. (Opcional) Para un despliegue de streaming, configure las opciones de inicio.

   • Initial mode

     Seleccione este modo para un nuevo despliegue o cuando no pueda reutilizar un estado existente. Según sus requisitos empresariales, también puede decidir si habilita Autopilot.

     Nota

     El modo inicial es un inicio sin estado que no reutiliza ningún estado. Desde la perspectiva de un conector de origen, equivale a un primer inicio, por lo que los parámetros de posición de inicio configurados en el DDL vuelven a surtir efecto. Por ejemplo, si una tabla de origen MySQL CDC establece scan.startup.mode en latest-offset, el despliegue lee solo desde el último offset actual después de iniciarse en modo inicial y no vuelve a escanear todos los datos históricos. Si se conserva el valor predeterminado initial, el despliegue vuelve a escanear todos los datos históricos.

     Si el almacenamiento ascendente tiene un límite de retención de datos, como el periodo de retención de registros de Simple Log Service (SLS) o el periodo de retención de mensajes de una cola de mensajes, el rango de datos que se lee nuevamente después de un inicio en modo inicial está restringido por dicho periodo de retención y puede diferir del rango de datos de la primera ejecución. Si el sink descendente sobrescribe datos por clave principal, evalúe el periodo de retención de datos ascendente antes de iniciar el despliegue en modo inicial para evitar sobrescrituras inesperadas en la tabla de resultados.

     Estrategia	Descripción
     Specify source's start time	Seleccione Specify source's start time e introduzca una hora específica. Puede establecer una hora de inicio en la interfaz de usuario para los siguientes siete conectores: Kafka, Log Service (SLS), DataHub, ApsaraMQ for RocketMQ, Hologres, Paimon y MySQL. La hora de lectura de datos especificada en la interfaz de inicio del despliegue tiene prioridad sobre el parámetro startTime establecido en el código DDL del despliegue. Nota Es posible que las versiones de Kafka anteriores a la 0.11 no sean compatibles debido a posibles incompatibilidades con la versión del cliente de Kafka que utiliza el conector. Se recomienda actualizar su versión de Kafka. No todos los conectores admiten la configuración del parámetro startTime. Para obtener más información, consulte los parámetros WITH de cada conector, como Log Service (SLS) WITH parameters, para comprobar si se incluye startTime. El parámetro startTime solo surte efecto cuando inicia un nuevo despliegue y especifica startTime. Si inicia un despliegue desde un checkpoint o un savepoint, especificar startTime no tiene ningún efecto.
     Configure Autopilot	Active este interruptor y seleccione un modo de ajuste: Modo Autopilot: El sistema reduce automáticamente los recursos cuando el uso es bajo y los aumenta cuando el uso alcanza un determinado umbral. Para obtener más información, consulte Enable and configure Autopilot. Modo programado: Debe seleccionar una programación en la lista desplegable. Una programación puede contener varias configuraciones de recursos para diferentes momentos. Puede configurar los recursos según los patrones de uso durante diversos periodos. Para obtener más información, consulte Configure and apply a scheduled tuning plan.

   • Resume mode

     Puede seleccionar una estrategia de inicio según sus requisitos empresariales y decidir si habilita Autopilot.

     Estrategia	Descripción
     Latest State	Reanuda el despliegue desde el último savepoint o checkpoint disponible. Si selecciona esta opción para un despliegue SQL, el sistema Flink detecta cambios en el código SQL, los parámetros de tiempo de ejecución de Flink y la versión del motor. Si se detectan cambios, se recomienda hacer clic en Click to detect junto a State Compatibility para comprobar la compatibilidad. Luego, proceda según los resultados. Para obtener información sobre los resultados de compatibilidad y las acciones sugeridas, consulte Compatibility.
     Specific State	Seleccione un savepoint específico desde el cual reanudar. Para saber cómo crear un savepoint, consulte Manage deployment state.
     Otro estado de despliegue	Después de seleccionar esta opción, especifique un despliegue de destino y su savepoint correspondiente para reanudar. Los savepoints se pueden compartir entre despliegues, pero el estado debe ser compatible. Para obtener más información, consulte Manage deployment state.
     Allow Non-restored State Nota Esta opción solo es compatible con despliegues JAR.	De forma predeterminada, Flink intenta asignar todo el savepoint a los operadores del nuevo despliegue. Si las modificaciones en el despliegue provocan cambios en el estado del operador, es posible que el despliegue no se reanude correctamente. Habilite esta opción para permitir que Flink omita cualquier estado que no se pueda asignar y continúe con el inicio. Para obtener más información, consulte Allow Non-Restored State.
     Configure Autopilot	Active este interruptor y seleccione un modo de ajuste: Modo Autopilot: El sistema reduce automáticamente los recursos cuando el uso es bajo y los aumenta cuando el uso alcanza un determinado umbral. Para obtener más información, consulte Enable and configure Autopilot. Modo programado: Debe seleccionar una programación en la lista desplegable. Una programación puede contener varias configuraciones de recursos para diferentes momentos. Puede configurar los recursos según los patrones de uso durante diversos periodos. Para obtener más información, consulte Configure and apply a scheduled tuning plan.

4. Haga clic en Start.

   En la página O&M > Deployments, consulte el estado del despliegue. Para obtener más información, consulte View deployment status.

Documentos relacionados

• Si necesita modificar los parámetros de tiempo de ejecución de un despliegue después de iniciarlo, consulte Configure runtime parameters. Algunos parámetros también admiten actualizaciones dinámicas, lo que evita el tiempo de inactividad asociado con detener y reiniciar los despliegues. Para obtener más información, consulte Dynamic scaling and dynamic parameter updates.

• Si necesita rastrear los datos de un despliegue después de iniciarlo para localizar problemas o evaluar el impacto, consulte View data lineage.

• Para obtener información sobre GeminiStateBackend de nivel empresarial y su comparación de rendimiento con RocksDBStateBackend, consulte Introduction to the enterprise-grade state backend.