Esto es lo que estoy tratando de hacer.

He creado dos nodos del clúster empresarial DataStax, sobre el cual he creado un programa java para obtener el recuento de una tabla (tabla de base de datos Cassandra).

Este programa fue construido en eclipse, que en realidad es de un cuadro de Windows.

En el momento de ejecutar este programa desde Windows, falla con el siguiente error en tiempo de ejecución:

El trabajo inicial no ha aceptado ningún recurso; verifique la interfaz de usuario de su clúster para asegurarse de que los trabajadores estén registrados y tengan suficiente memoria

El mismo código se compiló y ejecutó con éxito en esos clústeres sin ningún problema. ¿Cuál podría ser la razón por la que estoy superando el error?

Código:

import org.apache.spark.SparkConf;

import org.apache.spark.SparkContext;

import org.apache.spark.api.java.JavaSparkContext;
import org.apache.spark.sql.SchemaRDD;
import org.apache.spark.sql.cassandra.CassandraSQLContext;
import com.datastax.bdp.spark.DseSparkConfHelper;

public class SparkProject  {

    public static void main(String[] args) {

        SparkConf conf = DseSparkConfHelper.enrichSparkConf(new SparkConf()).setMaster("spark://10.63.24.14X:7077").setAppName("DatastaxTests").set("spark.cassandra.connection.host","10.63.24.14x").set("spark.executor.memory", "2048m").set("spark.driver.memory", "1024m").set("spark.local.ip","10.63.24.14X");

        JavaSparkContext sc = new JavaSparkContext(conf);

        CassandraSQLContext cassandraContext = new CassandraSQLContext(sc.sc());
        SchemaRDD employees = cassandraContext.sql("SELECT * FROM portware_ants.orders");

        //employees.registerTempTable("employees");
        //SchemaRDD managers = cassandraContext.sql("SELECT symbol FROM employees");
        System.out.println(employees.count());

        sc.stop();
    }
}