我完全遵循这个示例当我尝试运行时，我得到了这样的消息：我不知道如何修复它，因为我是使用Spark的新手。
浏览 2提问于2017-06-02得票数 1
回答已采纳
我这样启动Spark 1.6.1：我可以加载CSV文件而不会出现任何错误，如下所示：但是当我尝试像这样查看数据时：我得到的错误如下：
16/04/07 10:41:49 ERROR CsvRelation$: Exceptionwhile pars
浏览 0提问于2016-04-08得票数 0
我是斯卡拉和火花的初学者。火花版本: 3.0.1但我犯了个错误。failed 4 times, most recent failure: Lost task 0.3 in stage 0.0 (TID 7, 192.168.0.220, executor 0):
java.lang.ClassCastException20:54:19 INFO TaskSetManager: Lost task 1.3 in stage 0.0
浏览 4提问于2021-04-22得票数 4
AVRO消息，其中包含一个类型为long的字段时，我得到了以下错误：Caused by: java.lang.ClassCastException: java.lang.Long cannotbe cast to org.joda.time.DateTime
我使用Confluent 3.2.0和</
浏览 36提问于2017-12-18得票数 5
回答已采纳
2回答
我和星火的排课有很多问题。在我看来，排课是一门设计很差的课程。从Row提取值应该并不比从Scala列表中提取值更困难；但是在实践中，您必须知道列的确切类型才能提取它。, col2: int]
java.lang.ClassCastException: java.lang.Integerscala> df.first.getInt(0)
scala> df.first.getL
浏览 0提问于2018-03-23得票数 1
回答已采纳
我正在尝试使用Spark从Cassandra读取数据。WARN TaskSetManager: Lost task 1.0 in stage 0.0 (TID 1, ip-10-165-180-22.ec2.internal): java.lang.ClassCastException (o
浏览 2提问于2016-03-30得票数 2
在SparkSQL中定义UDT时，我会做出如下所示的UDT override def sqlType: DataType = StructType(Seq( StructField("loc", ArrayType(StructType(Seq( Stru
浏览 0提问于2018-12-04得票数 1
回答已采纳
我使用DataFrame来处理spark中的数据。我在这个数据帧中有一个数组列。在我要做的所有转换的最后，我得到了一个包含一个数组列和一行的dataframe。为了应用groupby、map和reduce，我想把这个数组作为一个列表，但我做不到。] (run-main-0) java.lang.ClassCastException: scala.collection.mutable.WrappedArray$ofRef cannot be castto scala.collection.immutable
浏览 33提问于2021-04-11得票数 0
我在集群模式和本地模式的spark上尝试简单的字数统计示例，它在本地模式下工作得很好，但在集群模式下抛出类强制转换异常这里是代码片段…16/02/21 03:18:05 ERROR Executor: Exception in task 1.0 in stagejava.
浏览 0提问于2016-02-21得票数 12
2回答
",header=T) java.lang.ClassCastException: java.lang.Booleancannot be cast to java.lang.String
at com.databricks.spark.csv.DefaultSource.createRela
浏览 8提问于2015-10-20得票数 2
回答已采纳
我正在尝试使用spark streaming来读取kafka主题中的数据。我可以将消息生成kafka主题，但当使用spark streaming读取主题中的数据时，我收到错误消息，如下所示：
ERROR ReceiverTracker: Deregistered receiverfor stream 0: Error starting receiver 0 - java.lang.ClassCastException: java.util.HashMap cannot
浏览 0提问于2019-05-27得票数 1
0回答
我们正在使用apache spark，我们将json文件保存为hdfs中的gzip压缩拼图文件。但是，在回读它们以生成数据帧时，某些文件(但不是所有文件)会导致以下异常：org.apache.parquet.io.ParquetDecodingExceptionCaused by: java.lang.ClassCastException:
org.apache.spark.sql
浏览 0提问于2018-07-12得票数 3
回答已采纳
df = spark.read.load(FilePath1,spark.conf.set").save(FilePath2)Caused by: org.apache.spark.SparkException: Job aborted due to stage failure3.0 in stage 86.0 (TID 282) (10.0.55
浏览 4提问于2022-06-09得票数 0
我使用的是getDouble(0)，其中索引0的值是"2“。我的假设是，字符串将被转换为加倍，但我得到的字符串不能被转换为双重错误。如果不将索引的值转换为双倍，那么如何使用getDouble？什么是首选的方法？？getString(0).toDouble
浏览 0提问于2017-04-04得票数 1
回答已采纳
1回答
如何在分区中转换行
、、、、
System.out.println(inrow.toString()); }获取误差 at org.apache.spark.sql.Row$class.getSeqinrow.length: 0
[]
浏览 3提问于2020-03-02得票数 1
回答已采纳
我有两个文件夹A和B A包含file1.csv.gz和file2.csv.gz，B包含file2.csv.gz和file3.csv.gz 我想在一个唯一的数据帧中读取这些文件。这就是我要做的： folders_to_read = ["A/*.csv.gz", "B/*.csv.gz"]
df = spark.read.format('csv').option("header"Py4JJavaError: An err
浏览 76提问于2020-04-21得票数 3
这个例子直接取自Spark example code，所以我有点迷惑，不知道是怎么回事。import org.apache.spark.sql.*;import org.apache.spark.sql.types.DataTypes工作人员总是失败，并出现以下错误： Caused by: java.lang.ClassCastException: cannot assign ins
浏览 64提问于2020-10-11得票数 1
2回答
import org.apache.spark.sql.._import org.apache.spark.ml.evaluation.ClusteringEvaluator// create spark session
implicit val spark = SparkSession.builder().appName("clustering").getOrCreate), r
浏览 0提问于2018-09-24得票数 0
(Task.scala:109) at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:345) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
浏览 2提问于2018-06-04得票数 2
]("features")我得到的错误是：
enter [error] (run-main-0) org.apache.spark.SparkException: Job aborted duein stage 13.0 failed 1 times, most recent failure: Lost task 0.0 in stage 13.0 (TID 13, localhost): java.lang.ClassCastException: org.apache.spark</e
浏览 0提问于2016-11-12得票数 4
云服务器
ICP备案
对象存储
云点播
即时通信 IM
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号