Scala - 找不到类型的即时转换器:scala.Tuple5

Scala - No instant converter found for type: scala.Tuple5

我有一些线路代码:

import org.joda.time._
import org.joda.time.format._
val sampleDate = new DateTime(2015, 1, 1, 0, 0)

所以我得到一个错误:

java.lang.IllegalArgumentException: No instant converter found for type: scala.Tuple5
    at org.joda.time.convert.ConverterManager.getInstantConverter(ConverterManager.java:165)
    at org.joda.time.base.BaseDateTime.<init>(BaseDateTime.java:169)
    at org.joda.time.DateTime.<init>(DateTime.java:168)
    at $iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:19)
    at $iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:24)
    at $iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:26)
    at $iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:28)
    at $iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:30)
    at $iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:32)
    at $iwC$$iwC$$iwC$$iwC.<init>(<console>:34)
    at $iwC$$iwC$$iwC.<init>(<console>:36)
    at $iwC$$iwC.<init>(<console>:38)
    at $iwC.<init>(<console>:40)
    at <init>(<console>:42)
    at .<init>(<console>:46)
    at .<clinit>(<console>)
    at .<init>(<console>:7)
    at .<clinit>(<console>)
    at $print(<console>)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:606)
    at org.apache.spark.repl.SparkIMain$ReadEvalPrint.call(SparkIMain.scala:852)
    at org.apache.spark.repl.SparkIMain$Request.loadAndRun(SparkIMain.scala:1125)
    at org.apache.spark.repl.SparkIMain.loadAndRunReq(SparkIMain.scala:674)
    at org.apache.spark.repl.SparkIMain.interpret(SparkIMain.scala:705)
    at org.apache.spark.repl.SparkIMain.interpret(SparkIMain.scala:669)
    at org.apache.spark.repl.SparkILoop.reallyInterpret(SparkILoop.scala:828)
    at org.apache.spark.repl.SparkILoop.interpretStartingWith(SparkILoop.scala:873)
    at org.apache.spark.repl.SparkILoop.command(SparkILoop.scala:785)
    at org.apache.spark.repl.SparkILoop.processLine(SparkILoop.scala:628)
    at org.apache.spark.repl.SparkILoop.innerLoop(SparkILoop.scala:636)
    at org.apache.spark.repl.SparkILoop.loop(SparkILoop.scala:641)
    at org.apache.spark.repl.SparkILoop$$anonfun$process.apply$mcZ$sp(SparkILoop.scala:968)
    at org.apache.spark.repl.SparkILoop$$anonfun$process.apply(SparkILoop.scala:916)
    at org.apache.spark.repl.SparkILoop$$anonfun$process.apply(SparkILoop.scala:916)
    at scala.tools.nsc.util.ScalaClassLoader$.savingContextLoader(ScalaClassLoader.scala:135)
    at org.apache.spark.repl.SparkILoop.process(SparkILoop.scala:916)
    at org.apache.spark.repl.SparkILoop.process(SparkILoop.scala:1011)
    at org.apache.spark.repl.Main$.main(Main.scala:31)
    at org.apache.spark.repl.Main.main(Main.scala)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:606)
    at org.apache.spark.deploy.SparkSubmit$.launch(SparkSubmit.scala:358)
    at org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:75)
    at org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala)

我不知道为什么会出现此错误,尽管在此网站中: https://www.joda.org/joda-time/apidocs/org/joda/time/DateTime.html 我看到这个构造器是正确的....

   DateTime

public DateTime(int year,
                int monthOfYear,
                int dayOfMonth,
                int hourOfDay,
                int minuteOfHour)
Constructs an instance from datetime field values using ISOChronology in the default time zone.
Parameters:
year - the year
monthOfYear - the month of the year
dayOfMonth - the day of the month
hourOfDay - the hour of the day
minuteOfHour - the minute of the hour
Since:
2.0

谢谢!!

您的代码适用于 2.7 version of joda-time, but it won't work with some older like 1.6:

2.7: DateTime(int year, int monthOfYear, int dayOfMonth, int hourOfDay, int minuteOfHour) 
1.6: DateTime(int year, int monthOfYear, int dayOfMonth, int hourOfDay, int minuteOfHour, int secondOfMinute, int millisOfSecond) 

因为 API 已更改。

我的回复:

scala> val sampleDate = new DateTime(2015, 1, 1, 0, 0)
warning: Class org.joda.convert.FromString not found - continuing with a stub.
warning: Class org.joda.convert.ToString not found - continuing with a stub.
warning: Class org.joda.convert.ToString not found - continuing with a stub.
warning: Class org.joda.convert.FromString not found - continuing with a stub.
warning: Class org.joda.convert.ToString not found - continuing with a stub.
sampleDate: org.joda.time.DateTime = 2015-01-01T00:00:00.000+07:00

如果我尝试了一些不合适的参数:

scala> val sampleDate = new DateTime(2015, 1, 1, 0)
java.lang.IllegalArgumentException: No instant converter found for type: scala.Tuple4

P.S。 joda-time jar 放在 lib_managed\jars 文件夹中。所以你可以在那里检查你的版本。我分别有 spark-1.2.0 和 joda-time-2.1.0,所以你至少应该 update 到 1.2.0 版本的 Spark 才能使用新的 API。