目前，以下是我的代码：import org.apache.log4j.Level;import org.apache.spark.api.java.JavaSparkContext;
import org.junit.Testcom.google.common.collect.
浏览 11提问于2017-06-26得票数 0
回答已采纳
1回答
使用的星火簇是火花-2.2.0bin-hadoop2.7.我将spark.jars.packages org.elasticsearch:elasticsearch-spark-20_2.11:5.4.1import org.apache.spark.SparkConfimport org.apache.spark.SparkContext&
浏览 14提问于2017-08-09得票数 0
我正在使用Spark和ElasticSearch，但是我不知道如何在ElasticSearch 2.x中使用Spark 2.X。ElasticSearch Spark libs只支持ES2.x的Spark1.6，支持ES5.alpha的Spark2。你用什么将Spark连接到ElasticSearch？
浏览 0提问于2016-09-20得票数 1
I am using below code for build.sbt:
"org.apache.spark" %% "spark-mllib" % "1.6.1",
"org.
浏览 3提问于2017-04-17得票数 0
package org.apache.spark.examples.streaming
import java.net.InetAddress
libraryDependencies += "org.apache.spark" %% &quo
浏览 1提问于2018-05-21得票数 3
回答已采纳
这是我的代码(使用Java和JDK 1.8_221)：import org.apache.spark.api.java.JavaPairRDD;import org.elasticsearch.spark.rdd.api.java.JavaEsSpark/spa
浏览 3提问于2019-10-30得票数 0
回答已采纳
我正在尝试运行简单的数据写入ElasticSearch示例。EsHadoopIllegalArgumentException: Cannot detect ES version - typically this happens if the network/Elasticsearch://dl.bintray.com/spark-packages/maven"
"org.apache.<em
浏览 0提问于2018-05-08得票数 1
回答已采纳
1回答
当我尝试使用esRDD("index")函数读取elasticsearch中的数据时，我得到了org.apache.spark.rdd.RDD[(String, scala.collection.Map然而，我在上看到，上面写着：
scalaVersion := "2.11.8"
libraryDependencies += &qu
浏览 4提问于2017-07-06得票数 3
回答已采纳
1回答
我想从elasticsearch中摄取最终的数据帧。我试过跟踪，但没能让它工作。import org.apache.spark.sql.functions._
import org.apache.spark.sql.SQLContextes.index.auto.create", "true&quo
浏览 0提问于2019-01-17得票数 0
1回答
org.apache.spark.SparkException:由于阶段失败而任务中止:阶段1.0中的任务0失败了1次，最近的失败:在阶段1.0中丢失了任务0.0 (TID 1，(本地主机)：org.elasticsearch.hadoop.rest.RestClient.discoverNodes(RestService.java:372) at org.elasticsearch.spark.rdd.EsRDDWriter.write(EsRDDWriter.斯卡拉:40)在org.elast
浏览 4提问于2015-12-12得票数 2
5回答
火花流弹性搜索依赖关系
、、、、
如所述，我正在尝试scala中的Spark & Elasticsearch集成[trace] Stack trace suppressed: run lastTotal time: 86 s, completed 19 nov. 2014 08:42:58name := "twitter-sparkstreaming-elasticsearchversion := "0.0.1"
scalaVersion := "
浏览 15提问于2014-11-19得票数 6
回答已采纳
我正在尝试通过Spark Scala从ElasticSearch读取数据。org.apache.spark.SparkConfimport org.apache.spark.SparkContextimport org.apache.spark.SparkContext._
import org.elasticsearch<
浏览 363提问于2020-02-04得票数 0
<dependency> <artifactId>elasticsearch-spark-20_2.11</artifactId$apache$spark$sql$execution$streaming$StreamExecution$$runStream(StreamExecution.scala:302)
atby: org
浏览 0提问于2019-09-03得票数 3
回答已采纳
3回答
at org.apache.spark.scheduler.DAGScheduler.runJob(DAGScheduler.scala:642) at org.apache.spark.internal.io.Sp
浏览 3提问于2019-09-19得票数 9
1回答
我们使用的是：Spark版本: 2.3.1，Elasticsearh集群版本: 6.5.4，elasticsearch版本: 6.5.4 at org.apache.spark.storage.BlockManager.doPut(BlockManager.scala:1018)
at org.apache.spark.storage.B
浏览 2提问于2019-01-06得票数 3
嗨，我正在尝试使用Scala2.11.12、Spark2.3.0和elasticsearch-20 7.7.0从OpenSearch 1.3.4索引中读取以下代码： at org.apache.spark.sql.DataFrameReader.loadV1Source(DataFrameReader.scala:239)
at org.apache.spark.sql.D
浏览 12提问于2022-08-17得票数 0
回答已采纳
spark-shell --jars /transfer/hdp/lib/elasticsearch-spark_2.10-2.3.2.jarimport org.elasticsearch.spark._
import org.elas
浏览 0提问于2016-06-21得票数 0
","org.apache.spark" %% "spark-hive" % sparkVersion % "provided"
libraryDependencies += "org.elastic
浏览 1提问于2016-12-13得票数 1
回答已采纳
1回答
我的Pyspark脚本需要org.elasticsearch.spark才能写入Elasticsearch。我在执行--packages org.elasticsearch:elasticsearch-spark-30_2.12:8.4.1脚本时提供了参数spark-submit，即在使用spark-submit:1764)
at org.apache.spark.deploy.SparkSubmit
浏览 68提问于2022-11-15得票数 0
我正在尝试用ElasticSearch保存一个JSON文件，但是它不能工作。这是我的代码：import org.apache.spark.sql.SQLContextimport org.apache.spark.SparkConf
def m
浏览 4提问于2018-07-19得票数 2
云服务器
对象存储
ICP备案
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号