Spark ClassCastException无法将FiniteDuration实例分配给字段RpcTimeout。Scala 2.10.5上的持续时间
当我试图提交一份工作时，我面临着这个例外。尝试什么？JAR是在Scala 2.10.5上编译的，并使用
Kafka2.10-0.8.2.0。罐子
Kafka客户端-0.8.2.0。罐子
下面是异常的完整堆栈跟踪
JAVAlang.ClassCastException:无法分配scala的实例。同时发生的期间对字段组织的限定。阿帕奇。火花rpc。RpcTimeout。scala类型的持续时间。同时发生的期间组织实例中的FiniteDuration。阿帕奇。火花rpc。RpcTimeout在java。木卫一。ObjectStreamClass$FieldReflector。setObjFieldValue（ObjectStreamClass.java:2133）~[na:1.8.0_74]在java上。木卫一。ObjectStreamClass。java上的setObjFieldValue（ObjectStreamClass.java:1305）~[na:1.8.0_74]。木卫一。ObjectInputStream。java上的defaultReadFields（ObjectInputStream.java:2006）~[na:1.8.0_74]。木卫一。ObjectInputStream。java上的readSerialData（ObjectInputStream.java:1924）~[na:1.8.0_74]。木卫一。ObjectInputStream。java上的readOrdinaryObject（ObjectInputStream.java:1801）~[na:1.8.0_74]。木卫一。ObjectInputStream。java上的readObject0（ObjectInputStream.java:1351）~[na:1.8.0_74]。木卫一。ObjectInputStream。java上的defaultReadFields（ObjectInputStream.java:2000）~[na:1.8.0_74]。木卫一。ObjectInputStream。java上的readSerialData（ObjectInputStream.java:1924）~[na:1.8.0_74]。木卫一。ObjectInputStream。java上的readOrdinaryObject（ObjectInputStream.java:1801）~[na:1.8.0_74]。木卫一。ObjectInputStream。java上的readObject0（ObjectInputStream.java:1351）~[na:1.8.0_74]。木卫一。ObjectInputStream。java上的defaultReadFields（ObjectInputStream.java:2000）~[na:1.8.0_74]。木卫一。ObjectInputStream。java上的readSerialData（ObjectInputStream.java:1924）~[na:1.8.0_74]。木卫一。ObjectInputStream。java上的readOrdinaryObject（ObjectInputStream.java:1801）~[na:1.8.0_74]。木卫一。ObjectInputStream。java上的readObject0（ObjectInputStream.java:1351）~[na:1.8.0_74]。木卫一。ObjectInputStream。org上的readObject（ObjectInputStream.java:371）~[na:1.8.0_74]。阿帕奇。火花序列化程序。JavaDeserializationStream。readObject（JavaSerializer.scala:76）~[spark-core_2.10-1.6.0-cdh5.12.0.jar:1.6.0-cdh5.12.0]位于org。阿帕奇。火花序列化程序。JavaSerialize实例。在org上反序列化（JavaSerializer.scala:109）~[spark-core_2.10-1.6.0-cdh5.12.0.jar:1.6.0-cdh5.12.0]。阿帕奇。火花rpc。内蒂。nettyrpcev$$anonfun$反序列化$1$$anonfun$应用$1。在scala上涂抹（Nettyrpcev.scala:261）~[spark-core_2.10-1.6.0-cdh5.12.0.jar:1.6.0-cdh5.12.0]。util。动态变量。在org上使用value（DynamicVariable.scala:57）~[correctedViewershipUserProfile-1.14-SNAPSHOT-jar-with-dependencies.jar:na]。阿帕奇。火花rpc。内蒂。Nettyrpcev。在org上反序列化（nettyrpcev.scala:313）~[spark-core_2.10-1.6.0-cdh5.12.0.jar:1.6.0-cdh5.12.0]。阿帕奇。火花rpc。内蒂。nettyrpcev$$anonfun$反序列化$1。在scala上涂抹（Nettyrpcev.scala:260）~[spark-core_2.10-1.6.0-cdh5.12.0.jar:1.6.0-cdh5.12.0]。util。动态变量。在org上使用value（DynamicVariable.scala:57）~[correctedViewershipUserProfile-1.14-SNAPSHOT-jar-with-dependencies.jar:na]。阿帕奇。火花rpc。内蒂。Nettyrpcev。在org上反序列化（nettyrpcev.scala:259）~[spark-core_2.10-1.6.0-cdh5.12.0.jar:1.6.0-cdh5.12.0]。阿帕奇。火花rpc。内蒂。NettyrpchHandler。内部接收（nettyrpcev.scala:590）~[spark-core_2.10-1.6.0-cdh5.12.0.jar:1.6.0-cdh5.12.0]。阿帕奇。火花rpc。内蒂。NettyrpchHandler。在org上接收（nettyrpcev.scala:572）~[spark-core_2.10-1.6.0-cdh5.12.0.jar:1.6.0-cdh5.12.0]。阿帕奇。火花网络萨斯勒。SaslrpchHandler。在org上接收（SaslRpcHandler.java:80）~[spark-network-common_2.10-1.6.0-cdh5.12.0.jar:1.6.0-cdh5.12.0]。阿帕奇。火花网络服务器TransportRequestHandler。ProcessrCrequest（TransportRequestHandler.java:154）[spark-network-common_2.10-1.6.0-cdh5.12.0.jar:1.6.0-cdh5.12.0]位于org。阿帕奇。火花网络服务器TransportRequestHandler。handle（TransportRequestHandler.java:102）[spark-network-common_2.10-1.6.0-cdh5.12.0.jar:1.6.0-cdh5.12.0]位于org。阿帕奇。火花网络服务器运输通道处理程序。channelRead0（TransportChannelHandler.java:104）[spark-network-common_2.10-1.6.0-cdh5.12.0.jar:1.6.0-cdh5.12.0]位于org。阿帕奇。火花网络服务器运输通道处理程序。channelRead0（TransportChannelHandler.java:51）[spark-network-common_2.10-1.6.0-cdh5.12.0.jar:1.6.0-cdh5.12.0]
共有1个答案
你用阴影罐吗？您可以尝试从kafka_2.10中排除scala库。
-
问题内容： 这是JDK的类方法。作者为什么将字段分配给局部变量？ 上面和下面之间有什么区别？这与线程安全有关吗？ 问题答案： 为了稍微扩展一下Michael的答案，我希望它可以确保该方法永不返回，而且还可以提供所提到的性能优势。 给出以下代码： 至少从理论上讲，在多线程代码中，可以将字段设置为第一次读取（）和第二次读取之间，然后将其返回。我没有看过其余的代码，但是我假设还有其他可能被分配的地方。对
-
我收到以下错误：
-
问题内容： 请参见下面的自包含示例。编译器在最后一行（由标记为）报告错误，在该行中，我将实例分配给它（根据我的最佳判断）符合的协议类型。如何编译？我究竟做错了什么？还是这个编译器问题？ 编辑： 即使我明确地向下转换了上面的返回类型（以便上面的代码片段的最后一行读取），如安东尼奥在调用函数时仍然存在编译错误： 问题答案： 首先，您想从devforums上读到规范的线程。您特别想跳过阅读jckarte
-
问题内容： 我有这样的数据结构： 是另一个结构。 然后，当我尝试在Users切片中添加一些新值时，如下所示： 我不断收到此错误： 还尝试在这里https://github.com/golang/go/issues/3117变通方法，像这样： 但是没有运气，仍然是完全相同的错误。 并且还尝试使用指针声明地图，因此：，仍然没有运气。 问题答案： 首先，对于这个问题，本文中的解决方案为什么在将值设置为结
-
问题内容： 我的任务是编写一个程序，要求用户输入5个存储在列表中的名称。接下来，它随机选择这些名称之一，并宣布该人为获胜者。唯一的问题是，当我尝试运行它时，它说。 这是我的代码： 我必须能够生成一个随机名称。 问题答案： 操作员的左侧需要为变量。您在这里所做的就是告诉python：“您知道数字1吗？将其设置为输入的字符串。”。是文字数字，而不是变量。始终是，您无法将其“设置”为其他内容。 变量就像
-
我想将任何持续时间/周期字符串文字（以下面示例中显示的格式）解析为Java中的周期/持续时间实例。 所谓持续时间/周期，我指的是包含基于日期和基于时间的数量的时间量。在Java中，仅适用于基于时间的量，如秒、分钟和小时，而，仅适用于日期量，如年、月和日。 要解析的字符串并不总是包含所有量。 例子： < li> < li> < li> < li> 如果可能的话，我会怎么做？