No puedo crear ni siquiera el archivo jar más básico para Apache Flink.
Tengo una tarea universitaria que requiere que use Apache Flink con muy poca orientación. Estudié algunos ejemplos de código y tengo una idea bastante clara de cómo escribir el código fuente. Pero no puedo, por ninguna razón, lograr compilarlo con éxito. Copié un ejemplo de YouTube solo para ver si puedo hacerlo funcionar, y resolví muchos errores en el camino, pero ahora estoy completamente desconcertado.
Básicamente, intento cargar un archivo jar básico, habiendo “hackeado” todas las dependencias de varias fuentes, debido a la falta de una guía completa sobre cómo configurarlo todo, y lo cargo a través del tablero de instrumentos en “localhost”. Me aseguré de especificar el punto de entrada (me llevó un tiempo entenderlo), pero al final obtengo un error que no tengo idea de cómo solucionar.
Copié el registro del Job Manager en un pastebin, porque pensé que contendría información útil, y realmente no sé cómo reducir esa información a algo útil.
Me he dado cuenta de que el registro se queja de la función print() (función de ejecución instantánea) en la línea 145, así que intenté cargar el archivo jar nuevamente, esta vez eliminando el print(), y obtengo un error diferente que dice:
2022-01-07 17:15:56,391 ERROR org.apache.flink.runtime.webmonitor.handlers.JarRunHandler [] - Se produjo una excepción en el controlador REST: No se incluyen trabajos en la aplicación.
He incluido la totalidad del segundo registro en este pastebin, pero siéntete libre de darme consejos basados únicamente en el primero, solo estoy publicando el segundo por si alguien lo necesita.
davy.ai
Parece que estás experimentando problemas al compilar y ejecutar tu aplicación Apache Flink. Aquí hay algunos pasos que puedes seguir para solucionar y resolver tu problema:
Paso 1: Verifica tus dependencias
Asegúrate de tener todas las dependencias necesarias para tu aplicación Flink. Si te falta una dependencia o tienes la versión incorrecta, esto puede causar problemas. Puedes utilizar una herramienta de gestión de dependencias como Maven o Gradle para ayudarte a administrar tus dependencias.
Paso 2: Verifica tu código
Asegúrate de que tu código Flink esté correctamente formateado y siga las mejores prácticas de Flink. Si ves errores relacionados con una línea específica de código, verifica esa línea para ver si hay errores de sintaxis u otros problemas obvios.
Paso 3: Verifica tu configuración
Asegúrate de que tu configuración Flink esté correctamente configurada. Puedes verificar tu archivo
flink-conf.yamlpara asegurarte de que todos los parámetros de configuración necesarios estén correctamente configurados. También puedes verificar los registros de tu Job Manager y Task Managers para ver si hay errores relacionados con la configuración.Paso 4: Verifica tu entorno
Asegúrate de que estás ejecutando Flink en un entorno adecuado. Si estás ejecutando Flink en una máquina virtual o un contenedor, por ejemplo, es posible que necesites asegurarte de que tu entorno esté correctamente configurado para admitir Flink.
Paso 5: Busca ayuda
Si sigues teniendo problemas, no dudes en buscar ayuda. Puedes comunicarte con la comunidad de Flink a través del canal Slack de Flink o a través de la lista de correo de Flink. También puedes consultar la documentación y los foros de Flink para obtener orientación.