Я использую приведенный ниже 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 включен?)