主线程java.lang.NoClassDefFoundError异常:org/apache/spark/sql/sql上下文
主线程java.lang.NoClassDefFoundError异常:org/apache/spark/sql/sql上下文是指在Java程序中，主线程在运行过程中发生了NoClassDefFoundError异常，该异常的具体信息是找不到org/apache/spark/sql/sql上下文类。
NoClassDefFoundError异常表示在编译时存在对某个类的引用，但在运行时找不到该类的定义。这通常是由于类路径配置错误或缺少相关的依赖库所致。
针对这个异常，可以采取以下几个步骤进行排查和解决：
- 检查类路径配置：确保所需的Spark相关库已正确添加到类路径中。可以通过在命令行或IDE中查看类路径配置来确认。
- 检查依赖库：确认是否缺少了org/apache/spark/sql/sql上下文类所在的依赖库。可以通过查看项目的构建文件（如pom.xml或build.gradle）来确认是否已正确添加相关依赖。
- 版本兼容性：检查所使用的Spark版本与代码中引用的类版本是否兼容。如果版本不匹配，可能会导致类找不到的异常。建议使用相同版本的Spark库。
- 重新编译和构建：尝试重新编译和构建项目，以确保所有依赖项都正确地包含在生成的输出中。
- 检查代码逻辑：检查代码中是否存在其他错误或逻辑问题，可能会导致类找不到的异常。特别是检查是否正确导入了所需的类。
对于Spark相关的问题，腾讯云提供了云原生的解决方案，可以使用腾讯云的云服务器、云数据库、云存储等产品来搭建和部署Spark集群。具体可以参考腾讯云的Spark产品介绍页面：腾讯云Spark产品介绍
请注意，以上答案仅供参考，具体解决方法可能因具体情况而异。在解决问题时，建议结合实际情况进行分析和调试。
相关·内容
2回答
我有一个spark应用程序，它对一个数据集运行多个测试，这些测试是包含诸如groupBy、filter等spark查询的函数.
Dataset<Row> dataset = loadDataset();
test1(dataset);
test2(dataset);
test3(dataset);
在这一点上，一切都很好，但是我可以看到集群被使用了大约30%，因此为了优化这一点，我考虑并行化测试以同时运行，因此我在一个线程中启动了每个测试：
Dataset<Row> dataset = loadDataset();
Thread thread1 = new Thread
浏览 0提问于2019-07-14得票数 2
回答已采纳
我们正在对冰山进行POC测试，并首次对其进行评估。
火花环境：
workers)Spark: spark-3.1.2-bin-hadoop3.2Scala：独立集群设置(1主服务器和5 2.12.10Java: 1.8.0_321Hadoop: 3.2.0Iceberg 0.13.1 )
正如Iceberg的官方文档中所建议的，为了在shell中添加对Iceberg的支持，我们在启动shell时添加了Iceberg依赖项，如下所示，
spark-shell --packages org.apache.iceberg:iceberg-spark-runtime-3.2_2.12:0.13.1
在
浏览 11提问于2022-04-07得票数 1
回答已采纳
1回答
我想在scala / sbt中的星火流项目中加入松弛api，当我运行这个程序时，我得到了一个类，而不是找到异常--我想是存在依赖问题吧？
错误：
Exception in thread "main" java.lang.NoClassDefFoundError: com/ullink/slack/simpleslackapi/listeners/SlackMessagePostedListener at org.apache.spark.sql.streaming.DataStreamReader.load(DataStreamReader.scala:175) at sun.
浏览 1提问于2018-09-28得票数 0
回答已采纳
1回答
我有一个奇怪的错误，我试图写数据给蜂巢，它在火花壳工作良好，但当我使用火花提交，它抛出数据库/表在默认错误中找不到。
下面是我试图在spark submit中编写的代码，我使用的是自定义构建的spark 2.0.0
val sqlContext = new org.apache.spark.sql.SQLContext(sc)
sqlContext.table("spark_schema.iris_ori")
下面是我使用的命令，
/home/ec2-user/Spark_Source_Code/spark/bin/spark-submit --class TreeClass
浏览 4提问于2016-05-20得票数 0
回答已采纳
1回答
凤凰星火插件
、、
插件更新是为了激发2.0吗？我不能用这个插件
val df = spark.read
.format("org.apache.phoenix.spark")
.option("table", "web_stat")
.option("zkUrl", "localhost:2181")
.option("driver","org.apache.phoenix.jdbc.PhoenixDriver")
浏览 2提问于2017-01-18得票数 1
我正在使用Spark 2.0，有时我的工作会因为输入问题而失败。例如，我正在根据日期从S3文件夹读取CSV文件，如果没有当前日期的数据，我的作业就没有什么要处理的，所以它抛出一个异常，如下所示。这会打印在司机的日志中。
Exception in thread "main" org.apache.spark.sql.AnalysisException: Path does not exist: s3n://data/2016-08-31/*.csv;
at org.apache.spark.sql.catalyst.analysis.CheckAnalysis$class
浏览 146提问于2016-09-03得票数 8
回答已采纳
我试着学习火花，但在这里我发现了一个异常(不允许设置org/apache/hadoop/hdfs/DistributedFileSystem).，它应该被静态地设置为跨会话使用，异常是在线程"main“java.lang.NoClassDefFoundError: java.lang.NoClassDefFoundError中的异常。)我正在windows 10个人电脑上工作。
主类：
package com.rakib;
import org.apache.spark.sql.Dataset;
import org.apache.spark.sql.Row;
import org.a
浏览 2提问于2020-08-17得票数 1
回答已采纳
当我使用以下命令时：
spark-submit --master spark://hadoop01:7077 --class org.apache.spark.examples.SparkPi
/data/spark-2.2.0-binhadoop2.7/examples/jars/spark-examples_2.11-2.2.0.jar
错误就会发生。
线程“main”java.lang.NoClassDefFoundError: org/apache/spark/sql/SparkSession中的异常
我的Hadoop环境是hdp 2.4.0.0-169。我怎样才能纠正错误
浏览 0提问于2018-03-01得票数 0
回答已采纳
我正在Kubernetes集群上运行一个简单的Spark作业，该作业使用Hive分类将数据写入HDFS。无论出于什么原因，我的应用程序都无法运行Spark SQL命令，但出现了以下异常： 21/09/22 09:23:54 ERROR SplunkStreamListener: |exception=org.apache.spark.sql.AnalysisException
org.apache.spark.sql.AnalysisException: org.apache.hadoop.hive.ql.metadata.HiveException: MetaException(messa
浏览 25提问于2021-09-22得票数 1
回答已采纳
我正在尝试使用配置单元上下文，但收到以下错误：
exception: java.lang.NoClassDefFoundError: org/apache/spark/sql/hive/HiveContext
有什么建议吗？
package com.mapr.examples;
import org.apache.spark.SparkConf;
import org.apache.spark.api.java.JavaSparkContext;
import org.apache.spark.sql.Row;
import org.apache.spark.sql.hive.HiveCo
浏览 2提问于2019-01-12得票数 2
我使用的是spark 1.6，当我运行以下代码时遇到了上面的问题：
// Imports
import org.apache.spark.sql.hive.HiveContext
import org.apache.spark.{SparkConf, SparkContext}
import org.apache.spark.sql.SaveMode
import scala.concurrent.ExecutionContext.Implicits.global
import java.util.Properties
import scala.concurrent.Future
// Se
浏览 2提问于2016-01-11得票数 16
当我试图在Scala (EclipseVersion4.7)中执行星火代码时，我得到了DataFrame代码的运行时异常。
import org.apache.spark.SparkConf
import org.apache.spark.SparkContext
import org.apache.spark.sql.SQLContext
object Demo {
def main(args:Array[String]){
val conf=new SparkConf().setAppName("Local App").setMaster("local[
浏览 0提问于2018-01-17得票数 2
1回答
我正在尝试使用submit命令(我正在使用scala)运行spark程序，我指定了主入口、类名、带有所有依赖项的jar文件、输入文件，然后是输出文件，但是我有和错误：
线程“主”(org.apache.spark.sql.execution.datasources.v2.csv.CSVDataSourceV2，org.apache.spark.sql.execution.datasources.csv.CSVFileFormat)，中的异常:为csv org.apache.spark.sql.AnalysisException找到的多个源请指定完全限定的类名。
这是一个错误的截图，它是关于什
浏览 5提问于2021-01-03得票数 1
1回答
我正在尝试使用Scala IDE中的Spark SQL，这是我在没有Maven的情况下设置的。我在生产环境中使用了Spark 1.5.1，并尝试通过执行以下代码
spark-submit --类com.dataflair.spark.Wordcount --主集群/home/appserver/Sparkjob.jar
package com.dataflair.spark
import org.apache.spark.SparkContext
import org.apache.spark.SparkConf
import org.apache.spark.SparkContext
im
浏览 0提问于2019-04-03得票数 0
3回答
我正在尝试转向星火流数据集(结构化流)，但我得到了一个AnalysisException (摘录如下)。
有人能确认在结构化流(Spark2.0)中确实不支持旋转吗？
线程“主”org.apache.spark.sql.AnalysisException中的异常:必须使用writeStream.start()执行流源查询；卡夫卡在org.apache.spark.sql.catalyst.analysis.UnsupportedOperationChecker$.org$apache$spark$sql$catalyst$analysis$UnsupportedOperationChecke
浏览 9提问于2017-12-01得票数 8
回答已采纳
我正在处理示例代码，下面是Apache的文档：
import java.util.Arrays;
import org.apache.spark.SparkConf;
import org.apache.spark.api.java.JavaSparkContext;
import org.apache.spark.ml.feature.CountVectorizer;
import org.apache.spark.ml.feature.CountVectorizerModel;
import org.apache.spark.sql.Data
浏览 1提问于2015-10-22得票数 1
2回答
我试图用IntellijIDEA中的线性回归在Spark中建立一个模型。
在拟合模型之前，我应该创建一个具有VectorAssembler列的feature。
import org.apache.spark.ml.feature.VectorAssembler
import org.apache.spark.ml.linalg.Vectors
//creating features column
val assembler = new VectorAssembler()
.setInputCols(Array("col4","col5","col6
浏览 4提问于2017-12-06得票数 0
我正在尝试使用spark-submit和Spark 2.1.0来读取Avro文件。
Maven依赖关系：
<dependency>
<groupId>org.apache.spark</groupId>
<artifactId>spark-core_2.11</artifactId>
<version>2.1.0</version>
</dependency>
<dependency>
<groupId>com.databricks</
浏览 12提问于2017-06-21得票数 1
回答已采纳
我在火花中实现了一些逻辑。此逻辑的执行取决于传递给Java代码的参数。在我的主要方法中，我有一个开关箱。当我传递一个正确的参数时，一切都正常。当我传递一些随机参数，这不是在我的开关情况下，我得到星火异常。以失败状态结束。
如果我在客户端模式下运行相同的代码，它不会抛出任何参数不正确的异常，我猜这是正确的行为。
只有当参数正确时，我才创建上下文。所以基本上，如果我在集群模式下给出一个空的主方法，我就会得到异常。
有人能解释一下这是怎么回事吗。我怎样才能避免这个例外。
public class MyClass{
private JavaSparkContext context = null;
pr
浏览 3提问于2016-06-30得票数 0
回答已采纳
我是scala和Spark的新手。我正在尝试读取csv文件，因此我创建了一个SparkSession来读取csv。此外，我还创建了一个SparkContext，以便稍后使用rdd。我正在使用scala-ide。
出现的错误可能是java中的常见错误，但我无法解决它们。
代码：
import org.apache.spark.{SparkConf, SparkContext}
import org.apache.spark.SparkContext._
import org.apache.spark.mllib.stat.Statistics
import org.apache.spark.sq
浏览 6提问于2018-04-06得票数 0
我想使用spark来处理hive表，但是当我运行我的程序时，我得到了以下错误：
线程“主”中的java.lang.IllegalArgumentException异常:无法用Hive支持实例化SparkSession，因为找不到Hive类。
我的应用程序代码
object spark_on_hive_table extends App {
val spark = SparkSession
.builder()
.appName("Spark Hive Example")
.config("spark.sql.warehouse.dir&#
浏览 1提问于2020-06-18得票数 2
回答已采纳
我尝试使用JRE 1.8.0在Eclipse中运行Spark应用程序，但遇到了以下异常。为什么？
Using Spark's default log4j profile: org/apache/spark/log4j-defaults.properties
18/04/01 17:05:30 INFO SparkContext: Running Spark version 1.4.1
Exception in thread "main" java.lang.NoClassDefFoundError: scala/collection/GenTraversableOnce
浏览 2提问于2018-04-01得票数 1
我尝试使用CassandraSQLContext从Spark查询Cassandra，但是我得到了一个奇怪的缺少依赖关系的错误。我有一个火花应用程序，如下所示：
val spark: SparkSession = SparkSession.builder().appName(appName).getOrCreate()
val cassandraSQLContext = new org.apache.spark.sql.cassandra.CassandraSQLContext(spark.sparkContext)
val path = args(0)
cassandraSQLContext
浏览 0提问于2019-03-20得票数 0
回答已采纳
我是一个spark的新手，当我试图运行我的第一个Spark SQL代码时被卡住了。我运行了一个简单的程序，使用eclipse IDE中的spark SQL加载了一个json文件。下面是我的代码：
SparkSession spSession = SparkSession.builder().appName("First SQL code").master("local[2]").config("spark.sql.warehouse.dir", tempDir).getOrCreate();
spSession.read().csv("d
浏览 2提问于2018-08-11得票数 0
我必须停止星星之火的结构化流查询。因此，首先，我检查状态是否有任何可用的数据在卡夫卡处理。如果是，则处理它，然后停止查询。
if (query.status.isDataAvailable) {
query.processAllAvailable()
}
query.stop()
在Jacek Laskowski的建议之后，我修改了实施方案。我有流媒体查询列表，
streamingQueryList.foreach{query =>
query.stop()
}
每次停止查询后，它都会抛出以下异常：
java.l
浏览 0提问于2017-11-13得票数 1
回答已采纳
我是Apache Spark的新手。我正在尝试使用Spark执行简单的spring boot应用程序，但是我得到了异常。
ERROR ApplicationMaster: User class threw exception:
java.lang.NoClassDefFoundError: org/springframework/boot/SpringApplication
java.lang.NoClassDefFoundError: org/springframework/boot/SpringApplication
Caused by: java.lang.ClassNotFoundE
浏览 5提问于2018-01-23得票数 1
回答已采纳
我使用maven为项目构建了*.jar文件。当我尝试执行主类时，在代码的某一行，它为类Exception in thread "main" java.lang.NoClassDefFoundError提供了错误org.apache.spark.ml.recommendation.ALS。
我运行火花-提交如下：
sudo -u hdfs /usr/bin/spark-submit --class
org.apache.spark.examples.ml.MyTest spark-examples-*.jar --rank 10 --path
/home/ubuntu/dat
浏览 5提问于2016-05-23得票数 0
在下面的错误中，相同的代码在Databricks中工作，但在Hdinsight中不起作用。我还在类路径中添加了delta库和hadoop-azure库。
io.delta:delta-core_2.11:0.5.0,org.apache.hadoop:hadoop-azure:3.1.3
ERROR ApplicationMaster [Driver]: User class threw exception: com.google.common.util.concurrent.ExecutionError: java.lang.NoClassDefFoundError: com/faster
浏览 6提问于2020-07-25得票数 3
3回答
我在我的build.sbt中添加了增量依赖项
libraryDependencies ++= Seq(
"org.apache.spark" %% "spark-core" % sparkVersion,
"org.apache.spark" %% "spark-sql" % sparkVersion,
"org.apache.spark" %% "spark-hive" % sparkVersion,
// logging
"org.apache.logging.log
浏览 3提问于2020-07-11得票数 0
回答已采纳
我试着用sedona和scala和sedona。下面是build.sbt文件：
ThisBuild / scalaVersion := "2.12.12"
libraryDependencies ++= Seq(
"org.apache.spark" % "spark-core_2.12" % "3.0.1",
"org.apache.spark" % "spark-sql_2.12" % "3.0.1",
"org.apache.sedona" % &
浏览 24提问于2022-10-13得票数 0
回答已采纳
1回答
我正在尝试加入以下两个数据处理程序：
val df1 = Seq(
("Verizon", "USA"),
("AT & T", "PK"),
("Verizon", "IND")
).toDF("Brand", "Country")
val df2 = Seq(
(8, "USA"),
(64, "UK"),
(-27, "DE&
浏览 0提问于2019-01-21得票数 0
1回答
在使用带有spark 1.6.2的HDP 2.5时，我们使用带有Tez的Hive作为它的执行引擎，并且它工作了。
但是，当我们使用spark 2.1.0迁移到HDP 2.6时，Hive没有使用Tez作为它的执行引擎，并且在调用DataFrame.saveAsTable API时引发了以下异常：
java.lang.NoClassDefFoundError: org/apache/tez/dag/api/SessionNotRunning at org.apache.hadoop.hive.ql.session.SessionState.start(SessionState.java:529)
浏览 3提问于2017-05-03得票数 3
一旦在dataset上调用了第一个操作，在Java中运行Spark程序就会立即失败，除非出现以下异常。已经尝试过中的所有建议，似乎没有什么可行的。尝试升级版本的火花仍然面临同样的错误。
请注意，不要使用spark-submit运行，但是通过下面的java -jar <app-name>是Spark配置：
compile group: 'org.apache.spark', name: 'spark-sql_2.12', version: '2.4.3'
implementation 'org.codehaus.
浏览 21提问于2021-10-07得票数 1
我在spark 2.0.0上测试我的spark代码，我遇到了一个bug SPARK-17463，我想使用spark 2.1.0，因为这个bug在这个版本中已经修复了。
但是，我无法调出spark 2.1.0的spark-shell with yarn客户端模式
我需要在HDP 2.5.3集群上运行2.1.0。
它抛出一个异常：
at org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:126)
at org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.sca
浏览 2提问于2017-02-16得票数 7
在Windows10中运行python代码时出现异常。我使用的是Apache Kafka和PySpark。 从Kafka读取数据的Python代码片段 ssc=StreamingContext(sc,60)
zkQuorum, topic = sys.argv[1:]
kvs=KafkaUtils.createStream(ssc, zkQuorum, "spark-streaming-consumer", {topic: 1})
lines = kvs.map(lambda x: [x[0],x[1]])
lines.pprint()
lines.foreac
浏览 41提问于2019-05-03得票数 2
我一直用scala中的spark从本地系统连接到Hive (它在集群中)，最后将我的hive-site.xml正确地放置在Spark/conf文件夹和类路径中，并且能够连接到转移，但无法访问蜂窝表。
如何更改HiveContext的用户
15/12/22 10:28:42 INFO ParseDriver:解析命令:显示表15/12/22 10:28:43 INFO ParseDriver: ParseDriver:解析完成15/12/22 10:28:45信息转移:试图连接到信息转移://server.com:9083 15/12/22 10:28:46 INFO JniBasedUnixG
浏览 2提问于2015-12-22得票数 0
回答已采纳
1回答
用图形火花sbt
、、
我是scala和sbt的新手，所以我不知道为什么会出错。
以下是我的build.sbt
name := "graphx-example"
version := "1.0"
scalaVersion := "2.11.8"
libraryDependencies ++= Seq(
"com.typesafe" % "config" % "1.3.1",
"org.scalatest" % "scalatest_2.11" % "3.0.4"
浏览 2提问于2017-11-11得票数 1
回答已采纳
我已经在单个节点上安装了apache-spark。当我运行spark-shell时，我得到了下面的异常。尽管有异常，我仍然可以创建RDDs并运行scala代码片段。
这是一个例外：
16/02/15 14:21:29 WARN ObjectStore: Failed to get database default, returning NoSuchObjectException
16/02/15 14:21:31 WARN : Your hostname, Rahul-PC resolves to a loopback/non-reachable address: fe80:0:0:0:c0c
浏览 0提问于2016-02-16得票数 1
我想从我的客户端节点上的cassandra节点读取数据：
这是我尝试过的：
spark-shell --jars /my-dir/spark-cassandra-connector_2.11-2.3.2.jar.
val df = spark.read.format("org.apache.spark.sql.cassandra")\
.option("keyspace","my_keyspace")\
.option("table","my_table")\
.option("spark.ca
浏览 0提问于2020-09-04得票数 1
下载了Apache3.2.0(最新版本)以及hadoop文件17.0.1
我甚至不能初始化
输入:
import pyspark
from pyspark.sql import SparkSession
spark = SparkSession.builder.getOrCreate()
df = spark.sql('''select 'spark' as hello ''')
df.show()
输出
Py4JJavaError: An error occurred while calling None.org.apache.
浏览 6提问于2021-10-23得票数 6
在spark提交的应用程序中，我得到了这个异常(2.4.0)
用户类抛出异常: org.apache.spark.sql.AnalysisException:多个资源为拼花找到org.apache.spark.sql.AnalysisException，请指定完全限定的类名。
我的应用程序是：
val sparkSession = SparkSession.builder()
.appName(APP_NAME)
.config("spark.sql.warehouse.dir", warehouseLocation)
.enable
浏览 0提问于2019-03-18得票数 0
我试图注册一个Spark，以帮助我从一个表中转换一个XML字符串，但是我得到了以下异常。我能知道我错过了什么吗？我正在使用Scala2.12.10和Spark2.4.4。
package org.mt.experiments
import org.apache.spark.sql.SparkSession
import scala.xml.transform.{RewriteRule, RuleTransformer}
import scala.xml.{Elem, Node, NodeSeq}
object Launcher2 {
case class Student(name:
浏览 10提问于2019-10-31得票数 1
回答已采纳
只有在使用mvn test运行所有测试用例时，我才会得到以下错误。如果我独立于IDE运行每个测试类，则不会发生这种情况。我正在使用https://github.com/MrPowers/spark-fast-tests框架。
性状
trait SparkSessionTestWrapper {
lazy val spark: SparkSession = {
SparkSession
.builder()
.master("local")
.appName("spark-fast-tests test session&#
浏览 9提问于2020-04-19得票数 2
回答已采纳
我有一个带有String[]的数据集，我很难从其中提取列。这是密码
import static org.apache.spark.sql.functions.col;
//Read parquet data
Dataset<Row> readerDF = spark.readStream().format("parquet").
List<String> columns = Arrays.asList("city","country");
//Interested in only field in data for n
浏览 1提问于2017-08-15得票数 0
回答已采纳
我正在运行下面的代码，在从Kafka读取了几个RDDs之后，我得到了这个Kafka多线程访问错误。不确定是什么导致了这种情况。基本上，代码所做的是从kafka读取CDR，并尝试将其放入全局临时视图中。简而言之，所有的RDDs /数据帧都必须存储在全局视图中。我使用的是Kafka 0.10和spark 2.1.1
val schema_string = "subscriberNumber, originNodeType, originHostName, originOperatorID, originTimeStamp, currentServiceClass, voucherBase
浏览 0提问于2018-05-06得票数 1
当你阅读地板文件在火花，如果你面临以下问题。
线程“主”org.apache.spark.SparkException中的App >异常:由于阶段失败而中止作业:阶段2.0中的任务0失败4次，最近的失败:阶段2.0中丢失的任务0.3 (TID 44，10.23.5.196，org.apache.parquet.io.DelegatingSeekableInputStream.readFully(DelegatingSeekableInputStream.java:104)应用程序> at org.apache.parquet.io.DelegatingSeekableInputS
浏览 2提问于2019-10-30得票数 5
回答已采纳
scala> augmentedDF1.write.format("com.mongodb.spark.sql.DefaultSource").option("database", "testdb").mode("overwrite").option("collection","e_logs").save()
java.lang.NoClassDefFoundError: scala/runtime/LazyBoolean
at com.mongodb.spark.sql.Default
浏览 1提问于2019-03-05得票数 2
运行kafka代码时
1)错误StreamExecution:查询id =c 6426655-446f-4306-91ba-d78e68e05c15，runId = 420382c1-8558-45a1-b26d-f6299044fa04，终止于错误java.lang.ExceptionInInitializerError。
2)线程中的异常流执行线程( id =c 6426655-446f-4306-91ba-d78e68e05c15，runId = 420382c1-8558-45a1-b26d-f6299044fa04“java.lang.ExceptionInInitializerE
浏览 0提问于2019-04-23得票数 0
如何在不使用javaRDD的情况下使用dataframe(spark sql)从Hbase获取数据。代码：-
SparkConf sconf = new SparkConf().setMaster("local").setAppName("Test");
Configuration conf = HBaseConfiguration.create();
JavaSparkContext jsc = new JavaSparkContext(sconf);
try {
HBaseAdmin.checkHBaseAvaila
浏览 4提问于2017-05-12得票数 0
使用集群，我的sbt构建的程序集jar可以通过SparkContext访问Cassandra。
然而，当我试图通过sqlContext访问时，我会得到远程集群上找不到的spark类--尽管我认为dataproc集群应该为spark提供服务。
java.lang.NoClassDefFoundError: org/apache/spark/sql/types/UTF8String$
at org.apache.spark.sql.cassandra.CassandraSQLRow$$anonfun$fromJavaDriverRow$1.apply$mcVI$sp(Cassand
浏览 5提问于2015-11-04得票数 2
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
云直播活动推荐
腾讯云开发者
