Ejecutar un programa Flink de muestra en local

Agregar los tres archivos Flink Jar como dependencias en su proyecto no es suficiente porque tienen otras dependencias transitivas, por ejemplo en Hadoop.

La forma más fácil de obtener una configuración funcional para desarrollar (y ejecutar localmente) programas de Flink es seguir la guía de inicio rápido que utiliza un arquetipo de Maven para configurar un proyecto de Maven. Este proyecto Maven puede importarse a su IDE.

Respuesta 1

NoClassDefFoundError extiende LinkageError

Se genera si la máquina virtual Java o una instancia de ClassLoader intenta cargar la definición de una clase (como parte de una llamada a método normal o como parte de la creación de una nueva instancia utilizando la nueva expresión) y no se puede encontrar una definición de la clase. La definición de clase buscada existía cuando se compiló la clase actualmente en ejecución, pero la definición ya no se puede encontrar.

Su código / jar depende de hadoop. Lo encontré aquí, descargue el archivo jar y agréguelo a su classpath org.apache.hadoop.mapreduce.InputFormat

Respuesta: 2

Después de cerrar una conexión de base de datos en Java, ¿puedo volver a abrirla? ¿O necesito volver a hacer DriverManager.getConnection ()?

Estoy usando String.split () para dividir una cadena. La cadena que recibo tiene esta estructura: [datos] <US> [datos] <US> donde <US> es el separador de unidad ASCII (código 0x1F). El código para dividir es ...

En primer lugar, soy nuevo en el desarrollo de Android, así que tenga paciencia conmigo. Comenzaré desde la interfaz de usuario, tengo un botón que una vez que lo tocas, comienza una actividad para obtener un resultado. clase pública GUIActividad ...

Estaba usando la "nueva" API de Hadoop 1.0.4 (clases en el paquete org.apache.hadoop.mapreduce). Cuando quería encadenar el mapeador / reductor, descubrí que ChainMapper, ChainReducer están escritos para la API "antigua" (...