чтение данных из упругого поиска через искровую Java - PullRequest
0 голосов
/ 07 ноября 2019

Я использую приведенный ниже Java-код для чтения URL-адреса es,

public static void main(String[] args) {

        SparkConf sparkConf = new SparkConf(true);
        sparkConf.setAppName(SparkMeasures.class.getName());
        sparkConf.setMaster("local[*]");
        sparkConf.set("spark.cleaner.ttl", "3600");
        sparkConf.set("es.nodes", "SMD-GUG-TC1");
        sparkConf.set("es.port", "9204");
        //sparkConf.set("es.resource.read", "test/doc");
        sparkConf.set("es.nodes.discovery", "false");
        sparkConf.set("es.nodes.wan.only", "true");
        sparkConf.set("es.field.read.empty.as.null", "true");
        sparkConf.set("es.nodes.client.only", "true");
        sparkConf.set("es.index.auto.create", "true");
        // http://SMD-GUG-TC1:9204/patient/

        SparkSession spark = null;
        try {


            spark = SparkSession.builder().config(sparkConf).getOrCreate();
            //spark = SparkSession.builder().set.config(sparkConf).getOrCreate();
////            JavaSparkContext jsc = new JavaSparkContext(sparkConf);

            SparkContext sc = spark.sparkContext();
            JavaSparkContext jsc = JavaSparkContext.fromSparkContext(sc);
            JavaPairRDD<String, java.util.Map<String, Object>> esRDD
                    = JavaEsSpark.esRDD(jsc, "patient/doc");
            esRDD.count();
        } catch (Exception e) {

            e.printStackTrace();
        }

, но получаю ошибку ниже,

org.elasticsearch.hadoop.EsHadoopIllegalArgumentException: Не удается найти узел с идентификатором[pqGdMxvTR8uHQnjCx5lwbw] (HTTP включен?)

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...