如图,在spark1.6中就没有这种问题,是新版本限制了什么吗?
import org.joda.time.{DateTime, Duration}case class Record(dateTime: DateTime)