Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.
Leí la visión general del modo de clúster (enlace: https://spark.apache.org/docs/latest/cluster-overview.html) y me preguntaba cómo se pueden mapear los componentes como el Driver, Executor y los nodos de trabajo en los componentes del Ecosistema Spark, como Spark Core, Spark SQL, Spark Streaming, Spark MLlib, Spark GraphX y los administradores de programación/cluster. . . . Read more
Intenté usar “future” dentro del servicio executor, funciona sin bloquear el hilo principal. Sin embargo, esto termina creando el doble de cantidad de hilos, lo cual no es deseable. En el siguiente código pude usar “future.get()” sin bloquear, pero tuve que crear el doble de cantidad de hilos. for (int . . . Read more
Creé un grupo de hilos (thread pool) y presenté dos tareas. ¿Por qué mi aplicación se cuelga sin excepciones después de imprimir “tarea uno, resultado: null”? private final static ThreadPoolExecutor executorService = new ThreadPoolExecutor(1, 1, 1L, TimeUnit.MINUTES, new SynchronousQueue<Runnable>(), new ThreadPoolExecutor.DiscardPolicy()); public static void main(String[] args) throws Exception { Future . . . Read more