Todos los productos
Search

Este producto

    Realtime Compute for Apache Flink:Manage custom connectors

    Centro de documentos

    Realtime Compute for Apache Flink:Manage custom connectors

    Última actualización: Sep 03, 2026

    Si los conectores integrados no cubren sus orígenes o destinos de datos, cargue un archivo JAR de conector personalizado para ampliar su espacio de trabajo de Flink. Este tema explica cómo registrar, usar y actualizar conectores personalizados.

    Requisitos previos

    Antes de empezar, asegúrese de contar con lo siguiente:

    Notas de uso

    Revise las siguientes restricciones antes de cargar su archivo JAR:

    Restricción

    Detalles

    Unicidad

    Cada tipo de conector solo se puede registrar una vez.

    Alineación de versiones

    La versión de Flink declarada en su pom.xml debe coincidir con la versión de la imagen de entorno de ejecución de Flink de su espacio de trabajo.

    Ámbito provided

    Agregue <scope>provided</scope> a las dependencias de Flink en su pom.xml. Cargar archivos JAR en la capa de entorno de ejecución provoca conflictos de dependencias.

    Empaquetado Shade

    Agrupe todas las dependencias de terceros (excepto las del entorno de ejecución de Flink) mediante el Maven Shade Plugin para evitar conflictos de classpath durante la ejecución.

    Registro de un conector personalizado

    1. Inicie sesión en el Portal de administración 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, haga clic en Connectors.

    4. En la pestaña Custom Connectors, haga clic en Create Custom Connector.

    5. Cargue su archivo JAR mediante uno de los siguientes métodos:

      • Upload File: Haga clic en Click to select y seleccione su archivo JAR de conector.

      • Use External URL: Introduzca la URL del archivo JAR alojado en un servicio externo. Ejemplo: https://ossbucket/artifacts/namespaces/flink-default/flink-jobs-1.0-SNAPSHOT.jar

        Nota

        Se admiten dos tipos de URL externas:

        • El bucket de OSS asociado a su espacio de trabajo de Flink. Consulte los detalles del bucket en la página Workspace Details del Portal de administración.

        • Una URL de un sistema de almacenamiento externo al que Realtime Compute for Apache Flink tenga acceso (lectura pública o con permiso otorgado).

    6. Haga clic en Next. Flink analiza sintácticamente el archivo JAR cargado. Si el análisis es correcto, continúe con el siguiente paso. Si falla, compruebe que el código de su conector cumple con los estándares de Apache Flink.

    7. Haga clic en Finish. El conector personalizado aparecerá en la lista de conectores.

    Uso de un conector personalizado en un trabajo

    Referencie el conector en el código SQL de su trabajo mediante la opción connector. El valor de la opción connector corresponde al valor del parámetro identificador de DynamicTableFactory en el paquete JAR de su conector personalizado. Las demás opciones del conector dependen de su implementación personalizada.

    Para obtener más información sobre cómo escribir SQL para trabajos, consulte Job development overview.

    Actualización de un conector personalizado

    Nota

    Actualizar un conector personalizado no afecta a los trabajos en ejecución. Los cambios surten efecto después de reiniciar el trabajo.

    1. Inicie sesión en el Portal de administración 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, haga clic en Connectors.

    4. En la pestaña Custom Connectors, localice el conector deseado y haga clic en Edit junto a su nombre.

    5. Cargue el nuevo archivo JAR mediante uno de los siguientes métodos:

      • Upload File: Haga clic en Click to select y seleccione su archivo JAR de conector.

      • Use External URL: Introduzca la URL del archivo JAR alojado en un servicio externo. Ejemplo: https://ossbucket/artifacts/namespaces/flink-default/flink-jobs-1.0-SNAPSHOT.jar

        Nota

        Se admiten dos tipos de URL externas:

        • El bucket de OSS asociado a su espacio de trabajo de Flink. Consulte los detalles del bucket en la página Details del Portal de administración.

        • Una URL de un sistema de almacenamiento externo al que Realtime Compute for Apache Flink tenga acceso (lectura pública o con permiso otorgado).

    6. Haga clic en Next. Flink analiza sintácticamente el archivo JAR cargado. Si el análisis es correcto, continúe con el siguiente paso. Si falla, compruebe que el código de su conector cumple con los estándares de Apache Flink.

    7. Haga clic en Finish.

    Pasos siguientes